wow-core/me.ahoo.wow.infra.sink

Package-level declarations

Types

ConcurrentManySink

class ConcurrentManySink<T : Any>(val delegate: Sinks.Many<T>) : Sinks.Many<T> , Decorator<Sinks.Many<T>>

Concurrent-emission Sinks.Many decorator.

Properties

val Scannable.cancelled: Boolean

val Scannable.terminated: Boolean

Functions

fun <T : Any> Sinks.Many<T>.concurrent(): ConcurrentManySink<T>

Makes every emission method of this sink safe for concurrent producers.