Package | Description |
---|---|
rx |
Rx Observables
|
rx.observables | |
rx.plugins | |
rx.subjects |
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
Observable.create(Observable.OnSubscribe<T> f)
Returns an Observable that will execute the specified function when a
Subscriber subscribes to
it. |
Constructor and Description |
---|
Observable(Observable.OnSubscribe<T> f)
Creates an Observable with a Function to execute when it is subscribed to.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractOnSubscribe<T,S>
Abstract base class for the
Observable.OnSubscribe interface that helps you build Observable sources one
onNext at a time, and automatically supports unsubscription and backpressure. |
Modifier and Type | Method and Description |
---|---|
static <K,T> GroupedObservable<K,T> |
GroupedObservable.create(K key,
Observable.OnSubscribe<T> f)
Returns an Observable that will execute the specified function when a
Subscriber subscribes to
it. |
Constructor and Description |
---|
ConnectableObservable(Observable.OnSubscribe<T> onSubscribe) |
GroupedObservable(K key,
Observable.OnSubscribe<T> onSubscribe) |
Modifier and Type | Method and Description |
---|---|
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f)
Invoked during the construction by
Observable.create(OnSubscribe) |
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance,
Observable.OnSubscribe<T> onSubscribe)
Invoked before
Observable.subscribe(rx.Subscriber) is about to be executed. |
Modifier and Type | Method and Description |
---|---|
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f)
Invoked during the construction by
Observable.create(OnSubscribe) |
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance,
Observable.OnSubscribe<T> onSubscribe)
Invoked before
Observable.subscribe(rx.Subscriber) is about to be executed. |
Constructor and Description |
---|
AsyncSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state) |
BehaviorSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state) |
PublishSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state) |
Subject(Observable.OnSubscribe<R> onSubscribe) |
TestSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state,
TestScheduler scheduler) |
Copyright © 2015. All Rights Reserved.