mobiuskt-core/kt.mobius/DiscardAfterDisposeConnectable

DiscardAfterDisposeConnectable

class DiscardAfterDisposeConnectable<I, O>(actual: Connectable<I, O>) : Connectable<I, O>

A Connectable that ensures that Connections created by the wrapped Connectable don't emit or receive any values after being disposed.

This only acts as a safeguard, you still need to make sure that the Connectable disposes of resources correctly.

Constructors

Link copied to clipboard
constructor(actual: Connectable<I, O>)

Functions

Link copied to clipboard
open override fun connect(output: Consumer<O>): Connection<I>

Create a new connection that accepts input values and sends outgoing values to a supplied consumer.