AbstractOutputChannel

Base OutputChannel implementation, handling isClosed checks and listener notification around write/flush on top of AbstractChannel, so that subclasses only need to implement the actual transport writes in writeActually/flushActually.

Constructors

constructor()

Whether this channel has been closed.

open override val streamTerm: Struct

The Prolog $stream(Direction, Id)-like Struct term identifying this channel, e.g. for current_output/1.

open override fun addListener(listener: Listener<T?>)

Registers listener to be invoked with every element subsequently transiting this channel.

open override fun clearListeners()

Unregisters every currently-registered Listener.

open override fun close()

override fun flush()

open override fun removeListener(listener: Listener<T?>)

Unregisters listener, previously added via addListener.

open override fun toString(): String

open fun <R> use(function: OutputChannel<T>.() -> R): R

Runs function against this channel, closeing it once function returns normally (not on exceptions).

override fun write(value: T)