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

Link copied to clipboard
constructor(capacity: Int = DEFAULT_CAPACITY)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
Link copied to clipboard
val events: SharedFlow<EventEnvelope>

Functions

Link copied to clipboard
fun publish(event: EventEnvelope): Boolean
Generated by Dokka
© 2026 Copyright