- class Receiver(parent, port_number)[source]
Bases:
objectThe
Receiverobject represents a downstream port on aStreamWrapperobject that gets messages from aSender.- Parameters
- parent
morpheus.pipeline.pipeline.StreamWrapper - port_numberint
Parent
StreamWrapperobject.Receiver port number.
- parent
- Attributes
- in_pair
- in_stream
- in_type
is_completeis_partial- parent
A receiver is complete if all input senders are also complete.
A receiver is partially complete if any input sender is complete.
Methods
Returns the input
StreamPairwhich is a tuple consisting of the parent node and the parent node's output type.link()The linking phase determines the final type of the
Receiverand connects all underlying stages.- get_input_pair()[source]
Returns the input
StreamPairwhich is a tuple consisting of the parent node and the parent node’s output type.- property is_complete
A receiver is complete if all input senders are also complete.
- property is_partial
A receiver is partially complete if any input sender is complete. Receivers are usually partially complete if there is a circular pipeline.
- link()[source]
The linking phase determines the final type of the
Receiverand connects all underlying stages.- Raises:
RuntimeError: Throws a
RuntimeErrorif the predicted input port type determined during the build phase is different than the current port type.
