ConversationStreamPublisher (longbridge-openapi 0.0.1 API)

java.lang.Object
- com.longbridge.agent.ConversationStreamPublisher

All Implemented Interfaces:

Flow.Publisher<ConversationStreamEvent>
```
public class ConversationStreamPublisher
extends Object
implements Flow.Publisher<ConversationStreamEvent>
```
A cold Flow.Publisher of ConversationStreamEvents.
Constructing this object (via AgentContext.conversationStream(java.lang.String, java.lang.String, java.lang.String) / AgentContext.continueConversationStream(java.lang.String, java.lang.String, java.lang.String, java.util.Map<java.lang.String, java.util.Map<java.lang.String, java.lang.String>>)) does not perform any I/O — per Reactive Streams convention, the underlying HTTP/SSE connection is only established once subscribe(java.util.concurrent.Flow.Subscriber<? super com.longbridge.agent.ConversationStreamEvent>) is called, and a fresh, independent connection is started for every subscriber.

- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void subscribe(Flow.Subscriber<? super ConversationStreamEvent> subscriber)
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - subscribe
```
public void subscribe(Flow.Subscriber<? super ConversationStreamEvent> subscriber)
```
    Specified by:
    
    subscribe in interface Flow.Publisher<ConversationStreamEvent>