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

Package-level declarations

Types

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

线程安全的 Sinks.Many 装饰器

Properties

Link copied to clipboard
val Scannable.cancelled: Boolean
Link copied to clipboard
val Scannable.terminated: Boolean

Functions

Link copied to clipboard
fun <T : Any> Sinks.Many<T>.concurrent(): ConcurrentManySink<T>
Generated by Dokka
© 2026 Copyright