public abstract class ChannelStep<I,O> extends CoroutineStep<I,O>
Channel
operations.Constructor and Description |
---|
ChannelStep(java.util.function.Function<Continuation<?>,ChannelId<O>> fGetChannelId)
Creates a new instance that operates on a channel the ID of which is
provided by a certain function that will be applied to the continuation
of an execution.
|
Modifier and Type | Method and Description |
---|---|
Channel<O> |
getChannel(Continuation<?> rContinuation)
Returns the channel this step operates on.
|
execute, fail, runAsync, runBlocking, terminateCoroutine, toString
deleteRelation, get, getRelation, getRelations, notifyRelationListeners, readRelations, relationsEqual, relationsHashCode, relationsString, set, set, transform, writeRelations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public ChannelStep(java.util.function.Function<Continuation<?>,ChannelId<O>> fGetChannelId)
fGetChannelId
- The function that will return the channel IDpublic Channel<O> getChannel(Continuation<?> rContinuation)
rContinuation
- The current continuation