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)
Content copied to clipboard