Package com.axelor.ai.chat.stream

Class StreamSubscription

java.lang.Object

com.axelor.ai.chat.stream.StreamSubscription

All Implemented Interfaces:

AutoCloseable

public class StreamSubscription
extends Object
implements AutoCloseable

Subscriber side of one run: replays chunks from the cache, then tails until the run ends. The topic is only a wake-up signal — every wake (or poll timeout) reads head and emits any chunks between the last emitted seq and head, so missed signals cannot lose data.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	StreamSubscription.ChunkConsumer

Method Summary

Modifier and Type	Method	Description
void	close()
void	pump(StreamSubscription.ChunkConsumer consumer, Duration maxDuration)	Streams chunks to consumer until the run is done or maxDuration elapses.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

pump

public void pump(StreamSubscription.ChunkConsumer consumer,
 Duration maxDuration)
          throws IOException

Streams chunks to consumer until the run is done or maxDuration elapses. Consumer IOExceptions propagate — the caller treats them as "client disconnected" and simply detaches; the run is unaffected.

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable