@class CNCancelationToken;
@protocol CNScheduler;

@interface _CNGeneratorObservable : CNObservable {
    id _state;
    id /* block */ _condition;
    id /* block */ _nextState;
    id /* block */ _resultSelector;
    id /* block */ _delay;
    id<CNScheduler> _scheduler;
    CNCancelationToken *_cancelable;
}

- (BOOL)isCanceled;
- (BOOL)isFinished;
- (void)updateState;
- (id)initWithInitialState:(id)a0 condition:(id /* block */)a1 nextState:(id /* block */)a2 resultSelector:(id /* block */)a3 delay:(id /* block */)a4 scheduler:(id)a5;
- (void)sendResultsToObserver:(id)a0;
- (void)scheduleNextResultForObserver:(id)a0;
- (id)subscribe:(id)a0;
- (void).cxx_destruct;
- (void)sendCurrentStateToObserver:(id)a0;

@end