io.enterpriseai.SseStream
Source : sdks/java/enterprise-ai-java/src/main/java/io/enterpriseai/SseStream.java. Retour à l'index de la référence du SDK Java.
Cette page est générée par tools/docs/gen_sdk_reference.py depuis les sources du SDK et les dossiers de textes OpenAPI. Ne la modifiez pas à la main : changez la source et régénérez.
Classe SseStream
Lecteur bloquant de Server-Sent Events. À utiliser avec try-with-resources, comme Iterator, Stream ou Flow.Publisher réactif. Un événement data: [DONE] termine le flux.
Iterator<SseEvent>, AutoCloseable
Constructeur SseStream
SseStream(InputStream in)
Lit les événements d'un flux d'octets décodé en UTF-8.
| Nom | Type | Défaut | Requis | Description |
|---|---|---|---|---|
in | InputStream | oui | Corps de la réponse HTTP text/event-stream. |
SseStream.close
void close()
Termine le flux et ferme le lecteur ; une connexion déjà rompue ne lève pas d'erreur.
Cet élément ne prend aucun paramètre.
Retour : void.
SseStream.publisher
Flow.Publisher<SseEvent> publisher(Executor executor)
Vue réactive qui respecte la contre-pression ; les événements sont lus sur l'executor donné.
| Nom | Type | Défaut | Requis | Description |
|---|---|---|---|---|
executor | Executor | oui | Executor sur lequel les événements sont lus. |
Retour : Flow.Publisher<SseEvent>. Un Flow.Publisher de SseEvent, un par événement reçu.
SseStream.stream
Stream<SseEvent> stream()
Stream paresseux des événements restants ; fermer le Stream ferme la connexion.
Cet élément ne prend aucun paramètre.
Retour : Stream<SseEvent>. Un Stream de SseEvent, un par événement reçu.