PipeElement

The PipeElement is a utility Element for testing and debugging pyllments flows by capturing and emitting arbitrary payloads. It can function as:

• An input sink: stores and inspects all payloads received on its pipe_input port.
• An output source: emits provided payloads into the flow via its pipe_output port.

Instantiation

Arguments:

receive_callback: callable = lambda x: x
Function invoked on each received payload for inspection or transformation. Should return a printable object for logging.

store_received_payloads: bool = True
Whether to append incoming payloads to the received_payloads list for later inspection.

Input Ports

Port Name	Payload Type	Behavior
pipe_input	Any	Receives any payload. If store_received_payloads is True, appends to received_payloads. Invokes receive_callback and fulfills send_and_receive futures.

Output Ports

Port Name	Payload Type	Behavior
pipe_output	Any	Emits payloads scheduled via send_payload or send_and_receive into the flow.

Methods

clear_received_payloads()

Clears all entries from the received_payloads list.

send_payload(payload: Any):

Emits a payload into the flow.

send_and_receive(payload: Any, timeout: float = None) -> Any:

Sends a payload and blocks until a response arrives on this pipe if the timeout is None, otherwise