org.apache.reef.wake.rx.impl

Class RxThreadPoolStage<T>

java.lang.Object

org.apache.reef.wake.rx.AbstractRxStage<T>

org.apache.reef.wake.rx.impl.RxThreadPoolStage<T>

Type Parameters:

T - type of event

All Implemented Interfaces:

AutoCloseable, Observer<T>, RxStage<T>, Stage

public final class RxThreadPoolStage<T>
extends AbstractRxStage<T>

Stage that executes the observer with a thread pool.

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 Summary

Constructors

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.

Method Summary

Methods

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.

Methods inherited from class org.apache.reef.wake.rx.AbstractRxStage

getInMeter, getOutMeter

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RxThreadPoolStage

@Inject
public RxThreadPoolStage(Observer<T> observer,
                        int numThreads)

Constructs a Rx thread pool stage.

Parameters:

observer - the observer to execute

numThreads - the number of threads

RxThreadPoolStage

@Inject
public RxThreadPoolStage(String name,
                        Observer<T> observer,
                        int numThreads)

Constructs a Rx thread pool stage.

Parameters:

name - the stage name

observer - the observer to execute

numThreads - the number of threads

Method Detail

onNext

public void onNext(T value)

Provides the observer with the new value.

Parameters:

value - the new value

onError

public void onError(Exception error)

Notifies the observer that the provider has experienced an error condition.

Parameters:

error - the error

onCompleted

public void onCompleted()

Notifies the observer that the provider has finished sending push-based notifications.

close

public void close()
           throws Exception

Closes the stage.

Throws:

Exception

getQueueLength

public int getQueueLength()

Gets the queue length of this stage.

Returns:

the queue length