T
- type of eventpublic final class RxThreadPoolStage<T> extends AbstractRxStage<T>
onNext
's will be arbitrarily subject to reordering, as with most stages.
All onNext
's for which returning from the method call
happens-before the call to onComplete
will maintain
this relationship when passed to the observer.
Any onNext
whose return is not ordered before
onComplete
may or may not get dropped.Constructor and Description |
---|
RxThreadPoolStage(Observer<T> observer,
int numThreads)
Constructs a Rx thread pool stage
|
RxThreadPoolStage(String name,
Observer<T> observer,
int numThreads)
Constructs a Rx thread pool stage
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the stage
|
int |
getQueueLength()
Gets the queue length of this 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 RxThreadPoolStage(Observer<T> observer, int numThreads)
observer
- the observer to executenumThreads
- the number of threads@Inject public RxThreadPoolStage(String name, Observer<T> observer, int numThreads)
name
- the stage nameobserver
- the observer to executenumThreads
- the number of threadspublic void onNext(T value)
value
- the new valuepublic void onError(Exception error)
error
- the errorpublic void onCompleted()
public int getQueueLength()
Copyright © 2015 The Apache Software Foundation. All rights reserved.