@class CNQueue, NSMutableArray;
@protocol CNScheduler;

@interface _CNFlatMapSubscriptionContext : NSObject

@property (readonly, nonatomic) CNQueue *decorators;
@property (readonly, nonatomic) NSMutableArray *tokens;
@property (readonly, nonatomic) id<CNScheduler> downstream;
@property (readonly, nonatomic) id<CNScheduler> resourceLock;
@property (nonatomic, getter=isOperatorReceiving) BOOL operatorReceiving;
@property (nonatomic, getter=isObserverReceiving) BOOL observerReceiving;

- (id)initWithSchedulerProvider:(id)a0;
- (void).cxx_destruct;

@end