http4k-realtime-core/org.http4k.sse

Package-level declarations

Types

PushAdaptingSse

abstract class PushAdaptingSse(val connectRequest: Request) : Sse

interface Sse : AutoCloseable

interface SseClient : AutoCloseable

typealias SseConsumer = (Sse) -> Unit

value class SseEventId(val value: String)

fun interface SseFilter : Function1<SseHandler, SseHandler>

typealias SseHandler = (Request) -> SseResponse

sealed interface SseMessage

interface SseResponse : Function1<Sse, Unit>

Properties

val SseFilter.Companion.NoOp: SseFilter

Functions

fun SseFilter(security: Security): SseFilter

fun SseFilter.then(next: SseHandler): SseHandler

fun SseFilter.then(routingSseHandler: RoutingSseHandler): RoutingSseHandler

fun SseFilter.then(next: SseFilter): SseFilter