PassthroughNode
abstract class PassthroughNode<InputT, OutputT, ChannelT : ChannelType<ChannelT>>(label: String, source: InputChannel<InputT, ChannelT>, destination: OutputChannel<OutputT, ChannelT>, sources: List<InputChannel<*, *>>, destinations: List<OutputChannel<*, *>>) : Node
Base class for nodes that process entities one-to-one from input to output while managing readiness. Subclasses implement process to transform entities and isReady to control flow. Automatically adapts to push/pull channel types.
Parameters
InputT
the type of incoming entities @param OutputT the type of outgoing entities @param ChannelT the channel type (Push or Pull)
label
the name of this node
source
the input channel from which entities are received
destination
the output channel where entities are sent
sources
the complete list of input channels
destinations
the complete list of output channels
Inheritors
Constructors
Link copied to clipboard
constructor(label: String, source: InputChannel<InputT, ChannelT>, destination: OutputChannel<OutputT, ChannelT>, sources: List<InputChannel<*, *>>, destinations: List<OutputChannel<*, *>>)