T
- typepublic final class RxSyncStage<T> extends AbstractRxStage<T>
Constructor and Description |
---|
RxSyncStage(Observer<T> observer)
Constructs a Rx synchronous stage.
|
RxSyncStage(String name,
Observer<T> observer)
Constructs a Rx synchronous stage.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the stage.
|
void |
onCompleted()
Notifies the observer that the provider has finished sending push-based
notifications.
|
void |
onError(Exception error)
Notifies the observer that the provider has experienced an error
condition.
|
void |
onNext(T value)
Provides the observer with the new value.
|
getInMeter, getOutMeter
@Inject public RxSyncStage(Observer<T> observer)
observer
- the observer@Inject public RxSyncStage(String name, Observer<T> observer)
name
- the stage nameobserver
- the observerpublic void onNext(T value)
value
- the new valuepublic void onError(Exception error)
error
- the errorpublic void onCompleted()
Copyright © 2017 The Apache Software Foundation. All rights reserved.