solve/it.unibo.tuprolog.solve.channel.impl/AbstractInputChannel

AbstractInputChannel

abstract class AbstractInputChannel<T : Any> : AbstractChannel<T> , InputChannel<T>

Base InputChannel implementation, adding a one-element lookahead queue on top of AbstractChannel so that peek and isOver both work without consuming an element, while subclasses only need to implement the actual blocking read in readActually.

Inheritors

ReaderChannel

Constructors

AbstractInputChannel

constructor()

Properties

available

open override val available: Boolean

isClosed

override var isClosed: Boolean

Whether this channel has been closed.

isOver

open override val isOver: Boolean

streamTerm

open override val streamTerm: Struct

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

Functions

addListener

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

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

clearListeners

open override fun clearListeners()

Unregisters every currently-registered Listener.

open override fun close()

peek

override fun peek(): T?

read

override fun read(): T?

removeListener

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

Unregisters listener, previously added via addListener.

toString

open override fun toString(): String

use

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

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