http4k-server-jetty/org.http4k.server/JettyEventStreamHandler

JettyEventStreamHandler

class JettyEventStreamHandler(sse: SseHandler, heartBeatDuration: Duration = Duration.ofSeconds(15)) : Handler.Abstract.NonBlocking(source)

Constructors

constructor(sse: SseHandler, heartBeatDuration: Duration = Duration.ofSeconds(15))

Types

Companion

object Companion

Properties

beans

open var beans: Collection<Any?>?

eventListeners

open override val eventListeners: List<EventListener?>?

invocationType

open val invocationType: Invocable.InvocationType?

isFailed

open override val isFailed: Boolean

isRunning

open override val isRunning: Boolean

isStarted

open override val isStarted: Boolean

isStarting

open override val isStarting: Boolean

isStopped

open override val isStopped: Boolean

isStopping

open override val isStopping: Boolean

server

@get:ManagedAttribute(value = "The Server associated with this Handler", readonly = true)

open var server: Server?

state

@get:ManagedAttribute(value = "Lifecycle State for this instance", readonly = true)

open val state: String?

Functions

addBean

open fun addBean(o: Any?): Boolean

open fun addBean(o: Any?, managed: Boolean): Boolean

addEventListener

open fun addEventListener(listener: EventListener?): Boolean

addManaged

open fun addManaged(o: Any?)

open fun addManaged(lifecycle: LifeCycle?)

contains

open operator fun contains(bean: Any?): Boolean

destroy

open fun destroy()

dump

open fun dump(out: Appendable?)

@ManagedOperation(value = "Dump the object to a string")

open fun dump(): String?

open fun dump(out: Appendable?, indent: String?)

dumpSelf

open fun dumpSelf(): String?

dumpStdErr

@ManagedOperation(value = "Dump the object to stderr")

open fun dumpStdErr()

getBean

open fun <T : Any?> getBean(clazz: Class<T?>?): T?

getCachedBeans

open fun <T : Any?> getCachedBeans(clazz: Class<T?>?): Collection<T?>?

getContainedBeans

open fun <T : Any?> getContainedBeans(clazz: Class<T?>?): Collection<T?>?

getEventListeners

open fun getEventListeners(): List<EventListener?>?

handle

open override fun handle(request: Request, response: Response, callback: Callback): Boolean

isAuto

open fun isAuto(bean: Any?): Boolean

isDumpable

open fun isDumpable(o: Any?): Boolean

isFailed

open fun isFailed(): Boolean

isManaged

open fun isManaged(bean: Any?): Boolean

isRunning

open fun isRunning(): Boolean

isStarted

open fun isStarted(): Boolean

isStarting

open fun isStarting(): Boolean

isStopped

open fun isStopped(): Boolean

isStopping

open fun isStopping(): Boolean

isUnmanaged

open fun isUnmanaged(bean: Any?): Boolean

manage

open fun manage(bean: Any?)

removeBean

open fun removeBean(o: Any?): Boolean

removeBeans

open fun removeBeans()

removeEventListener

open fun removeEventListener(listener: EventListener?): Boolean

setEventListeners

open fun setEventListeners(eventListeners: Collection<EventListener?>?)

start

fun start()

stop

fun stop()

unmanage

open fun unmanage(bean: Any?)

updateBean

open fun updateBean(oldBean: Any?, newBean: Any?)

open fun updateBean(oldBean: Any?, newBean: Any?, managed: Boolean)

updateBeans

open fun updateBeans(oldBeans: Array<out Any?>?, newBeans: Array<out Any?>?)

open fun updateBeans(oldBeans: Collection<*>?, newBeans: Collection<*>?)