Package rx

Interface Observable.OnSubscribe<T>

Type Parameters:
T - the output value type
All Superinterfaces:
Action, Action1<Subscriber<? super T>>, Function
All Known Implementing Classes:
AsyncOnSubscribe, AsyncOnSubscribe.AsyncOnSubscribeImpl, AsyncOnSubscribe.UnicastSubject.State, BufferUntilSubscriber.OnSubscribeAction, CachedObservable.CachedSubscribe, EmptyObservableHolder, NeverObservableHolder, Observable.OnSubscribeExtend, OnSubscribeAmb, OnSubscribeAutoConnect, OnSubscribeCollect, OnSubscribeCombineLatest, OnSubscribeConcatMap, OnSubscribeDefer, OnSubscribeDelaySubscription, OnSubscribeDelaySubscriptionOther, OnSubscribeDelaySubscriptionWithSelector, OnSubscribeDetach, OnSubscribeFilter, OnSubscribeFlattenIterable, OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable, OnSubscribeFromArray, OnSubscribeFromAsync, OnSubscribeFromCallable, OnSubscribeFromIterable, OnSubscribeGroupJoin, OnSubscribeGroupJoin.WindowObservableFunc, OnSubscribeJoin, OnSubscribeLift, OnSubscribeMap, OnSubscribeOnAssembly, OnSubscribePublishMulticast, OnSubscribeRange, OnSubscribeRedo, OnSubscribeReduce, OnSubscribeReduceSeed, OnSubscribeRefCount, OnSubscribeTakeLastOne, OnSubscribeThrow, OnSubscribeTimerOnce, OnSubscribeTimerPeriodically, OnSubscribeToObservableFuture.ToObservableFuture, OnSubscribeUsing, OperatorGroupBy.State, OperatorSubscribeOn, OperatorWithLatestFromMany, ReplaySubject.ReplayState, ScalarSynchronousObservable.JustOnSubscribe, ScalarSynchronousObservable.ScalarAsyncOnSubscribe, SubjectSubscriptionManager, SyncOnSubscribe, SyncOnSubscribe.SyncOnSubscribeImpl, UnicastSubject.State
Enclosing class:
Observable<T>

public static interface Observable.OnSubscribe<T> extends Action1<Subscriber<? super T>>
Invoked when Observable.subscribe is called.
  • Method Summary

    Methods inherited from interface rx.functions.Action1

    call