Conforms to NSObject
Declared in RACSubscribableProtocol.h

Tasks

Class Methods

combineLatest:

+ (RACSubscribable *)combineLatest:(NSArray *)subscribables

combineLatest:reduce:

+ (RACSubscribable *)combineLatest:(NSArray *)subscribables reduce:(id ( ^ ) ( RACTuple *xs ))reduceBlock

defer:

+ (RACSubscribable *)defer:(id<RACSubscribable> ( ^ ) ( void ))block

interval:

+ (RACSubscribable *)interval:(NSTimeInterval)interval

merge:

+ (RACSubscribable *)merge:(NSArray *)subscribables

whenAll:

+ (RACSubscribable *)whenAll:(NSArray *)subscribables

Instance Methods

aggregateWithStart:combine:

- (RACSubscribable *)aggregateWithStart:(id)start combine:(id ( ^ ) ( id running , id next ))combineBlock

aggregateWithStartFactory:combine:

- (RACSubscribable *)aggregateWithStartFactory:(id ( ^ ) ( void ))startFactory combine:(id ( ^ ) ( id running , id next ))combineBlock

all:

- (RACSubscribable *)all:(BOOL ( ^ ) ( id object ))predicateBlock

any

- (RACSubscribable *)any

any:

- (RACSubscribable *)any:(BOOL ( ^ ) ( id object ))predicateBlock

asCancelable

- (RACCancelableSubscribable *)asCancelable

asCancelableToSubject:withBlock:

- (RACCancelableSubscribable *)asCancelableToSubject:(RACSubject *)subject withBlock:(void ( ^ ) ( void ))block

asCancelableWithBlock:

- (RACCancelableSubscribable *)asCancelableWithBlock:(void ( ^ ) ( void ))block

asMaybes

- (RACSubscribable *)asMaybes

buffer:

- (RACSubscribable *)buffer:(NSUInteger)bufferCount

bufferWithTime:

- (RACSubscribable *)bufferWithTime:(NSTimeInterval)interval

catch:

- (RACSubscribable *)catch:(id<RACSubscribable> ( ^ ) ( NSError *error ))catchBlock

catchTo:

- (RACSubscribable *)catchTo:(id<RACSubscribable>)subscribable

concat

- (RACSubscribable *)concat

concat:

- (RACSubscribable *)concat:(id<RACSubscribable>)subscribable

delay:

- (RACSubscribable *)delay:(NSTimeInterval)interval

deliverOn:

- (RACSubscribable *)deliverOn:(RACScheduler *)scheduler

distinctUntilChanged

- (RACSubscribable *)distinctUntilChanged

doCompleted:

- (RACSubscribable *)doCompleted:(void ( ^ ) ( void ))block

doError:

- (RACSubscribable *)doError:(void ( ^ ) ( NSError *error ))block

doNext:

- (RACSubscribable *)doNext:(void ( ^ ) ( id x ))block

finally:

- (RACSubscribable *)finally:(void ( ^ ) ( void ))block

first

- (id)first

firstOrDefault:

- (id)firstOrDefault:(id)defaultValue

firstOrDefault:success:error:

- (id)firstOrDefault:(id)defaultValue success:(BOOL *)success error:(NSError **)error

groupBy:

- (RACSubscribable *)groupBy:(id<NSCopying> ( ^ ) ( id object ))keyBlock

groupBy:transform:

- (RACSubscribable *)groupBy:(id<NSCopying> ( ^ ) ( id object ))keyBlock transform:(id ( ^ ) ( id object ))transformBlock

injectObjectWeakly:

- (RACSubscribable *)injectObjectWeakly:(id)object

let:

- (RACSubscribable *)let:(RACSubscribable *( ^ ) ( RACSubscribable *sharedSubscribable ))letBlock

merge

- (RACSubscribable *)merge

merge:

- (RACSubscribable *)merge:(RACSubscribable *)subscribable

multicast:

- (RACConnectableSubscribable *)multicast:(RACSubject *)subject

publish

- (RACConnectableSubscribable *)publish

repeat

- (RACSubscribable *)repeat

retry

- (RACSubscribable *)retry

retry:

- (RACSubscribable *)retry:(NSInteger)retryCount

scanWithStart:combine:

- (RACSubscribable *)scanWithStart:(id)start combine:(id ( ^ ) ( id running , id next ))combineBlock

select:

- (RACSubscribable *)select:(id ( ^ ) ( id x ))selectBlock

selectMany:

- (RACSubscribable *)selectMany:(id<RACSubscribable> ( ^ ) ( id x ))selectBlock

sequenceMany:

- (RACSubscribable *)sequenceMany:(id<RACSubscribable> ( ^ ) ( void ))block

sequenceNext:

- (RACSubscribable *)sequenceNext:(id<RACSubscribable> ( ^ ) ( void ))block

skip:

- (RACSubscribable *)skip:(NSUInteger)skipCount

skipUntilBlock:

- (RACSubscribable *)skipUntilBlock:(BOOL ( ^ ) ( id x ))block

skipWhileBlock:

- (RACSubscribable *)skipWhileBlock:(BOOL ( ^ ) ( id x ))block

startWith:

- (RACSubscribable *)startWith:(id)initialValue

subscribe:

- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber

subscribeCompleted:

- (RACDisposable *)subscribeCompleted:(void ( ^ ) ( void ))completedBlock

subscribeError:

- (RACDisposable *)subscribeError:(void ( ^ ) ( NSError *error ))errorBlock

subscribeError:completed:

- (RACDisposable *)subscribeError:(void ( ^ ) ( NSError *error ))errorBlock completed:(void ( ^ ) ( void ))completedBlock

subscribeNext:

- (RACDisposable *)subscribeNext:(void ( ^ ) ( id x ))nextBlock

subscribeNext:completed:

- (RACDisposable *)subscribeNext:(void ( ^ ) ( id x ))nextBlock completed:(void ( ^ ) ( void ))completedBlock

subscribeNext:error:

- (RACDisposable *)subscribeNext:(void ( ^ ) ( id x ))nextBlock error:(void ( ^ ) ( NSError *error ))errorBlock

subscribeNext:error:completed:

- (RACDisposable *)subscribeNext:(void ( ^ ) ( id x ))nextBlock error:(void ( ^ ) ( NSError *error ))errorBlock completed:(void ( ^ ) ( void ))completedBlock

subscribeOn:

- (RACSubscribable *)subscribeOn:(RACScheduler *)scheduler

switch

- (RACSubscribable *)switch

take:

- (RACSubscribable *)take:(NSUInteger)count

takeLast:

- (RACSubscribable *)takeLast:(NSUInteger)count

takeUntil:

- (RACSubscribable *)takeUntil:(id<RACSubscribable>)subscribableTrigger

takeUntilBlock:

- (RACSubscribable *)takeUntilBlock:(BOOL ( ^ ) ( id x ))predicate

takeWhileBlock:

- (RACSubscribable *)takeWhileBlock:(BOOL ( ^ ) ( id x ))predicate

throttle:

- (RACSubscribable *)throttle:(NSTimeInterval)interval

timeout:

- (RACSubscribable *)timeout:(NSTimeInterval)interval

toArray

- (NSArray *)toArray

toProperty:onObject:

- (RACDisposable *)toProperty:(NSString *)keyPath onObject:(NSObject *)object

where:

- (RACSubscribable *)where:(BOOL ( ^ ) ( id x ))whereBlock

windowWithStart:close:

- (RACSubscribable *)windowWithStart:(id<RACSubscribable>)openSubscribable close:(id<RACSubscribable> ( ^ ) ( id<RACSubscribable> start ))closeBlock