Inherits from NSObject
Conforms to RACSubscribable
Declared in RACSubscribable.h

Properties

didSubscribe

@property (nonatomic, copy) RACDisposable *^ ) ( id<RACSubscriber> subscriber ) didSubscribe

subscribers

@property (nonatomic, strong) NSMutableArray *subscribers

Class Methods

combineLatest:reduce:

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

createSubscribable:

+ (id)createSubscribable:(RACDisposable *( ^ ) ( id<RACSubscriber> subscriber ))didSubscribe

defer:

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

empty

+ (id)empty

error:

+ (id)error:(NSError *)error

interval:

+ (RACSubscribable *)interval:(NSTimeInterval)interval

merge:

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

never

+ (id)never

return:

+ (id)return:(id)value

start:

+ (id)start:(id ( ^ ) ( BOOL *success , NSError **error ))block

startWithScheduler:block:

+ (id)startWithScheduler:(RACScheduler *)scheduler block:(id ( ^ ) ( BOOL *success , NSError **error ))block

whenAll:

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

Instance Methods

aggregateWithStart:combine:

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

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:(id<RACSubscribable>)subscribable

delay:

- (RACSubscribable *)delay:(NSTimeInterval)interval

deliverOn:

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

distinctUntilChanged

- (RACSubscribable *)distinctUntilChanged

doNext:

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

finally:

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

first

- (id)first

firstOrDefault:

- (id)firstOrDefault:(id)defaultValue

groupBy:

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

groupBy:transform:

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

let:

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

merge

- (RACSubscribable *)merge

merge:

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

multicast:

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

performBlockOnEachSubscriber:

- (void)performBlockOnEachSubscriber:(void ( ^ ) ( id<RACSubscriber> subscriber ))block

publish

- (RACConnectableSubscribable *)publish

repeat

- (RACSubscribable *)repeat

scanWithStart:combine:

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

select:

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

selectMany:

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

skip:

- (RACSubscribable *)skip:(NSUInteger)skipCount

startWith:

- (RACSubscribable *)startWith:(id)initialValue

subscribeOn:

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

switch

- (RACSubscribable *)switch

take:

- (RACSubscribable *)take:(NSUInteger)count

takeUntil:

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

takeUntilBlock:

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

tearDown

- (void)tearDown

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