Package com.tnsai.coordination.streaming

package com.tnsai.coordination.streaming

Streaming inter-agent communication with backpressure support.

Provides push-based streaming channels for agents to exchange data with configurable flow control. Supports SSE-like patterns within the JVM.

• StreamingChannel - Typed streaming channel with backpressure
• BackpressureStrategy - Overflow handling strategies
• AgentStreamBridge - Named channel registry for multi-agent streaming

See Also:

• Choreography-based coordination

Related Packages

Package	Description
com.tnsai.coordination	Multi-agent coordination patterns and shared problem-solving infrastructure.

Class	Description
AgentStreamBridge	Bridges streaming channels between agents for push-based inter-agent communication.
BackpressureStrategy	Defines how a StreamingChannel handles overflow when the buffer is full.
StreamingChannel<T>	A typed streaming channel for inter-agent communication with configurable backpressure.
StreamingChannel.BufferOverflowException	Exception thrown when backpressure strategy is ERROR and buffer is full.
StreamingChannel.Builder<T>
StreamingChannel.ChannelMetrics	Channel metrics snapshot.