Uses of Class
com.tnsai.coordination.streaming.StreamingChannel

Packages that use StreamingChannel

Package	Description
com.tnsai.coordination.streaming	Streaming inter-agent communication with backpressure support.

Uses of StreamingChannel in com.tnsai.coordination.streaming

Methods in com.tnsai.coordination.streaming that return StreamingChannel

Modifier and Type	Method	Description
StreamingChannel<T>	StreamingChannel.Builder.build()
<T> StreamingChannel<T>	AgentStreamBridge.createChannel(String name, Class<T> type)	Creates a named streaming channel.
<T> StreamingChannel<T>	AgentStreamBridge.createChannel(String name, Class<T> type, int bufferSize, BackpressureStrategy backpressure)	Creates a named streaming channel with custom settings.
StreamingChannel<T>	StreamingChannel.filter(Predicate<T> predicate)	Creates a new channel that only passes items matching the predicate.
<T> StreamingChannel<T>	AgentStreamBridge.getChannel(String name, Class<T> type)	Gets an existing channel by name.
<R> StreamingChannel<R>	StreamingChannel.map(Function<T,R> mapper)	Creates a new channel that applies a transformation to each item.
StreamingChannel<T>	StreamingChannel.onComplete(Runnable handler)	Registers a completion handler.
StreamingChannel<T>	StreamingChannel.onError(Consumer<Throwable> handler)	Registers an error handler.
StreamingChannel<T>	StreamingChannel.subscribe(Consumer<T> consumer)	Subscribes a consumer to receive values from this channel.