mobiuskt-core/kt.mobius/SafeConnectable

SafeConnectable

class SafeConnectable<F, E>(actual: Connectable<F, E>) : Connectable<F, E>

A Connectable that ensures that an inner Connection doesn'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

SafeConnectable

constructor(actual: Connectable<F, E>)

Types

class SafeConsumer<E>(actual: Consumer<E>) : Connection<E>

SafeEffectConsumer

class SafeEffectConsumer<F>(actual: Connection<F>) : Connection<F>

Functions

open override fun connect(output: Consumer<E>): Connection<F>

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