WebSocketEvents

Enables support for event streaming over WebSockets. Supposed to be used in pair with dev.d1s.ktor.events.server.route.webSocketEvents route builder.

Example usage:

val pool = InMemoryEventPool()

install(WebSocketEvents) {
eventPool = pool
}

routing {
webSocketEvents()
}

val createdBook = createBook()
val reference = ref("book_created")
val event = event(reference, createdBook)

pool.push(event)

See also