Struct ConversationStreamSubscription 

pub struct ConversationStreamSubscription { /* private fields */ }

Bridges a conversation event [Stream] to a Reactive-Streams-style consumer with real backpressure, matching java.util.concurrent.Flow.Subscription’s request(n)/cancel() contract. Only Java’s Flow.Publisher exposure needs this — every other binding either pulls synchronously (conversation_stream_iter) or has no flow control at all (drive_conversation_stream).

Implementations

impl ConversationStreamSubscription

pub fn spawn<S, F1, F2, F3>( stream: S, on_next: F1, on_error: F2, on_complete: F3, ) -> Self

where S: Stream<Item = Result<ConversationStreamEvent>> + Send + 'static, F1: Fn(ConversationStreamEvent) + Send + Sync + 'static, F2: FnOnce(Error) + Send + 'static, F3: FnOnce() + Send + 'static,

Spawn a background task that waits for demand, pulls one item at a time from stream once demand is available, and dispatches on_next/on_error/on_complete (each of these is expected to call back into the JVM via a JNI Subscriber reference).

Drains all the way to the stream’s natural end rather than stopping as soon as a ConversationStreamEvent::WorkflowFinished is seen — against the real API, the server sometimes emits a few more housekeeping events (e.g. a chat_title_updated-shaped ConversationStreamEvent::Other) after workflow_finished and before actually closing the connection, so stopping early would silently drop them and abandon the connection while the server still had something to say.

pub fn request(&self, n: u64)

Called from Flow.Subscription.request(n) (any JVM thread).

pub fn cancel(&self)

Called from Flow.Subscription.cancel().