SafeConsumer

Constructors

constructor(actual: Consumer<E>)

open override fun accept(value: E)

Send a value this connection. Implementations may receive values from different threads and are thus expected to be thread-safe.

open override fun dispose()

Disconnect this connection and dispose of all resources associated with it.