invoke

operator fun invoke(block: EventStream.Builder.() -> Unit): EventStream