method SseWriter.send

use std.http { Server, ServerConfig, ServerHandle, Router, Request, Reply, Client, Header, HttpConfig, Response, WebSocket, WsConfig, WsKind, WsMessage, SseWriter, SseStream, SseConfig, SseEvent, BodyWriter, Http2, Http2Handle, ResponseStream, chunks }

fn run() -> () | NetError | DecodeError | Panicked  net, io, time {
  let srv = Server.bind(ServerConfig{ port: 0, followNode: false })?
  defer srv.close()
  let stop = srv.handle()
  let base = "http://127.0.0.1:{srv.port()}"
  let router = Router.new().get("/ticks", (req: Request) => Reply.sse((w: SseWriter) => {
    for i in [1, 2, 3] {
      w.send("tick {i}")?
    }
  }))
  scope {
    spawn stop.serve(router)
    let s = SseStream.open("{base}/ticks")?
    defer s.close()
    var more = true
    while more {
      match s.next(5s)? {
        ev? => print(ev.text)
        none => more = false
      }
    }
    stop.shutdown()
    ()
  }?
}

fn main() io, net, time {
  match run() {
    NetError _ => print("net error")
    DecodeError _ => print("decode error")
    Panicked _ => print("panicked")
    _ => {}
  }
}

tick 1
tick 2
tick 3