def event

bend-kit-llm@0.13.0.1 · llm.bend:573

import Base
import bend-kit-llm@0.13.0.1/sse.bend as Sse
import bend-kit-http@0.38.1.1/http.bend as Http

573# The next SSE event, or None when the stream ends. An event the end cuts off is dropped.
574def event(s: Stream) -> IO(Stream & Result<&1, &1, Err, Maybe<&1, Sse.Message>>):
575  Stream{+api, h, rd} = s
576  do IO<Stream & Result<&1, &1, Err, Maybe<&1, Sse.Message>>>:
577    x : Http.Stream & Sse.Reader & Result<&1, &1, Err, Maybe<&1, Sse.Message>> <- event.loop(Nat.mul(65536n, 256n), RnNext{h, Sse.next(rd)})
578    return event.done(api, x)