Package | Description |
---|---|
rx |
Rx Observables
|
rx.functions | |
rx.observables | |
rx.observers |
Modifier and Type | Interface and Description |
---|---|
static interface |
Observable.OnSubscribe<T>
Invoked when Observable.subscribe is called.
|
Modifier and Type | Method and Description |
---|---|
Observable<T> |
Observable.doOnEach(Action1<Notification<? super T>> onNotification)
Modifies the source Observable so that it invokes an action for each item it emits.
|
Observable<T> |
Observable.doOnError(Action1<Throwable> onError)
Modifies the source Observable so that it invokes an action if it calls
onError . |
Observable<T> |
Observable.doOnNext(Action1<? super T> onNext)
Modifies the source Observable so that it invokes an action when it calls
onNext . |
Observable<T> |
Observable.doOnRequest(Action1<Long> onRequest)
Modifies the source
Observable so that it invokes the given action when it receives a request for
more items. |
void |
Observable.forEach(Action1<? super T> onNext)
Subscribes to the
Observable and receives notifications for each element. |
void |
Observable.forEach(Action1<? super T> onNext,
Action1<Throwable> onError)
Subscribes to the
Observable and receives notifications for each element and error events. |
void |
Observable.forEach(Action1<? super T> onNext,
Action1<Throwable> onError)
Subscribes to the
Observable and receives notifications for each element and error events. |
void |
Observable.forEach(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Subscribes to the
Observable and receives notifications for each element and the terminal events. |
void |
Observable.forEach(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Subscribes to the
Observable and receives notifications for each element and the terminal events. |
Observable<T> |
Observable.onBackpressureDrop(Action1<? super T> onDrop)
Instructs an Observable that is emitting items faster than its observer can consume them to discard,
rather than emit, those items that its observer is not prepared to observe.
|
Subscription |
Observable.subscribe(Action1<? super T> onNext)
Subscribes to an Observable and provides a callback to handle the items it emits.
|
Subscription |
Observable.subscribe(Action1<? super T> onNext,
Action1<Throwable> onError)
Subscribes to an Observable and provides callbacks to handle the items it emits and any error
notification it issues.
|
Subscription |
Observable.subscribe(Action1<? super T> onNext,
Action1<Throwable> onError)
Subscribes to an Observable and provides callbacks to handle the items it emits and any error
notification it issues.
|
Subscription |
Observable.subscribe(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Subscribes to an Observable and provides callbacks to handle the items it emits and any error or
completion notification it issues.
|
Subscription |
Observable.subscribe(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Subscribes to an Observable and provides callbacks to handle the items it emits and any error or
completion notification it issues.
|
static <T,Resource> |
Observable.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Observable<? extends T>> observableFactory,
Action1<? super Resource> disposeAction)
Constructs an Observable that creates a dependent resource object which is disposed of on unsubscription.
|
static <T,Resource> |
Observable.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Observable<? extends T>> observableFactory,
Action1<? super Resource> disposeAction,
boolean disposeEagerly)
Constructs an Observable that creates a dependent resource object which is disposed of just before
termination if you have set
disposeEagerly to true and unsubscription does not occur
before termination. |
Modifier and Type | Method and Description |
---|---|
static <T0> FuncN<Void> |
Functions.fromAction(Action1<? super T0> f)
|
static <T1> Func1<T1,Void> |
Actions.toFunc(Action1<T1> action)
Converts an
Action1 to a function that calls the action and returns null . |
static <T1,R> Func1<T1,R> |
Actions.toFunc(Action1<T1> action,
R result)
Converts an
Action1 to a function that calls the action and returns a specified value. |
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 |
---|---|
abstract void |
ConnectableObservable.connect(Action1<? super Subscription> connection)
Instructs the
ConnectableObservable to begin emitting the items from its underlying
Observable to its Subscriber s. |
static <T,S> AbstractOnSubscribe<T,S> |
AbstractOnSubscribe.create(Action1<AbstractOnSubscribe.SubscriptionState<T,S>> next)
Creates an
AbstractOnSubscribe instance which calls the provided next action. |
static <T,S> AbstractOnSubscribe<T,S> |
AbstractOnSubscribe.create(Action1<AbstractOnSubscribe.SubscriptionState<T,S>> next,
Func1<? super Subscriber<? super T>,? extends S> onSubscribe)
Creates an
AbstractOnSubscribe instance which creates a custom state with the onSubscribe
function and calls the provided next action. |
static <T,S> AbstractOnSubscribe<T,S> |
AbstractOnSubscribe.create(Action1<AbstractOnSubscribe.SubscriptionState<T,S>> next,
Func1<? super Subscriber<? super T>,? extends S> onSubscribe,
Action1<? super S> onTerminated)
Creates an
AbstractOnSubscribe instance which creates a custom state with the onSubscribe
function, calls the provided next action and calls the onTerminated action to release the
state when its no longer needed. |
static <T,S> AbstractOnSubscribe<T,S> |
AbstractOnSubscribe.create(Action1<AbstractOnSubscribe.SubscriptionState<T,S>> next,
Func1<? super Subscriber<? super T>,? extends S> onSubscribe,
Action1<? super S> onTerminated)
Creates an
AbstractOnSubscribe instance which creates a custom state with the onSubscribe
function, calls the provided next action and calls the onTerminated action to release the
state when its no longer needed. |
void |
BlockingObservable.forEach(Action1<? super T> onNext)
Invokes a method on each item emitted by this
BlockingObservable and blocks until the Observable
completes. |
Modifier and Type | Method and Description |
---|---|
static <T> Subscriber<T> |
Subscribers.create(Action1<? super T> onNext)
Creates a
Subscriber that receives the emissions of any Observable it subscribes to via
onNext but ignores onError and
onCompleted notifications. |
static <T> Observer<T> |
Observers.create(Action1<? super T> onNext)
Creates an
Observer that receives the emissions of any Observable it subscribes to via
onNext but ignores onCompleted notifications;
it will throw an OnErrorNotImplementedException if onError is invoked. |
static <T> Subscriber<T> |
Subscribers.create(Action1<? super T> onNext,
Action1<Throwable> onError)
Creates an
Subscriber that receives the emissions of any Observable it subscribes to via
onNext and handles any onError notification but
ignores an onCompleted notification. |
static <T> Subscriber<T> |
Subscribers.create(Action1<? super T> onNext,
Action1<Throwable> onError)
Creates an
Subscriber that receives the emissions of any Observable it subscribes to via
onNext and handles any onError notification but
ignores an onCompleted notification. |
static <T> Observer<T> |
Observers.create(Action1<? super T> onNext,
Action1<Throwable> onError)
Creates an
Observer that receives the emissions of any Observable it subscribes to via
onNext and handles any onError notification but ignores
an onCompleted notification. |
static <T> Observer<T> |
Observers.create(Action1<? super T> onNext,
Action1<Throwable> onError)
Creates an
Observer that receives the emissions of any Observable it subscribes to via
onNext and handles any onError notification but ignores
an onCompleted notification. |
static <T> Subscriber<T> |
Subscribers.create(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Creates an
Subscriber that receives the emissions of any Observable it subscribes to via
onNext and handles any onError or
onCompleted notifications. |
static <T> Subscriber<T> |
Subscribers.create(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Creates an
Subscriber that receives the emissions of any Observable it subscribes to via
onNext and handles any onError or
onCompleted notifications. |
static <T> Observer<T> |
Observers.create(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Creates an
Observer that receives the emissions of any Observable it subscribes to via
onNext and handles any onError or
onCompleted notifications. |
static <T> Observer<T> |
Observers.create(Action1<? super T> onNext,
Action1<Throwable> onError,
Action0 onComplete)
Creates an
Observer that receives the emissions of any Observable it subscribes to via
onNext and handles any onError or
onCompleted notifications. |
Copyright © 2015. All rights reserved.