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.