Jetty11EventStreamEmitter

class Jetty11EventStreamEmitter(connectRequest: Request, output: OutputStream, heartBeatDuration: Duration, scheduler: Scheduler, onClose: (Jetty11EventStreamEmitter) -> Unit) : PushAdaptingSse, Runnable, LifeCycle.Listener

Constructors

constructor(connectRequest: Request, output: OutputStream, heartBeatDuration: Duration, scheduler: Scheduler, onClose: (Jetty11EventStreamEmitter) -> Unit)

open override fun close()

open fun lifeCycleFailure(p0: LifeCycle, p1: Throwable)

open fun lifeCycleStarted(p0: LifeCycle)

open fun lifeCycleStarting(p0: LifeCycle)

open fun lifeCycleStopped(p0: LifeCycle)

open override fun lifeCycleStopping(event: LifeCycle)

open override fun onClose(fn: () -> Unit)

open override fun run()

open override fun send(message: SseMessage)