server-ktor/io.devconsole.server.ktor/EventStreamHub

EventStreamHub

class EventStreamHub(capacity: Int = DEFAULT_CAPACITY)

Bounded live stream of envelopes that have already crossed the capture redaction boundary.

Constructors

constructor(capacity: Int = DEFAULT_CAPACITY)

Types

object Companion

Properties

currentSequence

val currentSequence: Long

val events: SharedFlow<EventEnvelope>

Functions

fun publish(event: EventEnvelope): Boolean