-
Base class for
Transport-backed channels with managed I/O loops.
Strategy for computing the delay between retry attempts.
A logical messaging channel between two endpoints.
A
Channel that sends requests and receives correlated responses.
Structured context for a channel error, carrying the cause and any associated request/response.
Reads a message from an input stream.
Writes a message to an output stream.
Identifies the traffic direction for a channel, used as an OTel metric attribute.
Handles an incoming request by completing the given future with a response.
A
Channel backed by a
Transport that receives requests and dispatches them to a
registered handler.
A
MultiplexedChannel where request and response types are the same (
T=T),
enabling bidirectional symmetric messaging on a single connection.
Pluggable I/O transport that provides input/output streams and connection metadata.
Factory for creating new
Transport instances.
Callback for inbound messages that could not be correlated to a pending request in a
MultiplexedChannel.