co.paralleluniverse.strands.channels.transfer

Class Pipeline<S,T>

java.lang.Object

co.paralleluniverse.strands.channels.transfer.Pipeline<S,T>

All Implemented Interfaces:

SuspendableCallable<java.lang.Long>, java.io.Serializable

public class Pipeline<S,T>
extends java.lang.Object
implements SuspendableCallable<java.lang.Long>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Pipeline(ReceivePort<? extends S> from, SendPort<? super T> to, SuspendableAction2<S,Channel<T>> transformer)
Pipeline(ReceivePort<? extends S> from, SendPort<? super T> to, SuspendableAction2<S,Channel<T>> transformer, int parallelism)
Pipeline(ReceivePort<? extends S> from, SendPort<? super T> to, SuspendableAction2<S,Channel<T>> transformer, int parallelism, boolean closeTo)
Pipeline(ReceivePort<? extends S> from, SendPort<? super T> to, SuspendableAction2<S,Channel<T>> transformer, int parallelism, boolean closeTo, SuspendableCallable<Channel<T>> resultChannelBuilder)
Pipeline(ReceivePort<? extends S> from, SendPort<? super T> to, SuspendableAction2<S,Channel<T>> transformer, int parallelism, boolean closeTo, SuspendableCallable<Channel<T>> resultChannelBuilder, StrandFactory strandFactory)

Method Summary

Modifier and Type	Method and Description
long	getTransferred()
java.lang.Long	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

Pipeline

public Pipeline(ReceivePort<? extends S> from,
                SendPort<? super T> to,
                SuspendableAction2<S,Channel<T>> transformer,
                int parallelism,
                boolean closeTo,
                SuspendableCallable<Channel<T>> resultChannelBuilder,
                StrandFactory strandFactory)

Pipeline

public Pipeline(ReceivePort<? extends S> from,
                SendPort<? super T> to,
                SuspendableAction2<S,Channel<T>> transformer,
                int parallelism,
                boolean closeTo,
                SuspendableCallable<Channel<T>> resultChannelBuilder)

Pipeline

public Pipeline(ReceivePort<? extends S> from,
                SendPort<? super T> to,
                SuspendableAction2<S,Channel<T>> transformer,
                int parallelism,
                boolean closeTo)

Pipeline

public Pipeline(ReceivePort<? extends S> from,
                SendPort<? super T> to,
                SuspendableAction2<S,Channel<T>> transformer,
                int parallelism)

Pipeline

public Pipeline(ReceivePort<? extends S> from,
                SendPort<? super T> to,
                SuspendableAction2<S,Channel<T>> transformer)

Method Detail

getTransferred

public long getTransferred()

run

public java.lang.Long run()
                   throws SuspendExecution,
                          java.lang.InterruptedException

Specified by:

run in interface SuspendableCallable<java.lang.Long>

Throws:

SuspendExecution

java.lang.InterruptedException