molecule.channel.PutChan

Trait for blocking system-level output channels.

This interface assumes that put_! and close methods are invoked sequentially.

This trait is useful to wrap legacy blocking output interfaces and can easily be wrapped in a non-blocking OChan using the wrap method in the companion object (see the implementation of molecule.channel.Console for examples).

A: The type of messages.

Source: PutChan.scala

Linear Supertypes

AnyRef, Any

Abstract Value Members

abstract def close(signal: Signal): Unit

Close this channel.
Close this channel.
Subsequently to a call to this method, any new segment written to this channel will be poisoned. Contrarily to the poison method on input channels, messages buffered are not poisoned and may still be read by a consumer listening on the other end of this channel.
signal
the termination signal.
returns
Unit
abstract def put_!(as: Seg[A]): PutChan[A]

Put a segment on this channel.
Put a segment on this channel.
This method may block if there is no space available on the channel.
returns
The continuation of this channel on which the next message must be put.

Concrete Value Members

final def !=(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def !=(arg0: Any): Boolean

Definition Classes
Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def ==(arg0: Any): Boolean

Definition Classes
Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws()
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws()
final def getClass(): java.lang.Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws()
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws()
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws()

PutChan

trait PutChan[-A] extends AnyRef

Abstract Value Members

abstract def close(signal: Signal): Unit

abstract def put_!(as: Seg[A]): PutChan[A]

Concrete Value Members

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): java.lang.Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from AnyRef

Inherited from Any