molecule.stream.ochan.immutable.VoidOChan

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
abstract def :+:(seg: Seg[Any]): OChan[Any]

[use case] Adds a segment in front of this output.
[use case]
Adds a segment in front of this output.
seg
the segment to prepend.
returns
an output which produces seg as first segment and which continues with the remaining of the stream.

Definition Classes
OChan
def :+:[B <: Any](seg: Seg[B])(implicit arg0: Message[B]): OChan[B]

Adds a segment in front of this output.
Adds a segment in front of this output.
seg
the segment to prepend.
returns
an output which produces seg as first segment and which continues with the remaining of the stream.

Definition Classes
OChan
abstract def :+:(x: Any): OChan[Any]

[use case] Adds a message in front of this output.
[use case]
Adds a message in front of this output.
x
the message to prepend.
returns
an output which produces x as first message and which continues with the remaining of the stream.

Definition Classes
OChan
def :+:[B <: Any](x: B)(implicit arg0: Message[B]): OChan[B]

Adds a message in front of this output.
Adds a message in front of this output.
x
the message to prepend.
returns
an output which produces x as first message and which continues with the remaining of the stream.

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

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

Definition Classes
Any
def add[B](transformer: (OChan[Any]) ⇒ OChan[B])(implicit arg0: Message[B]): OChan[B]

Add a stream transformer to this channel.
Add a stream transformer to this channel.
returns
the transformed channel

Definition Classes
VoidOChan → OChan
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws()
def close(signal: Signal): Unit

Close the channel
Close the channel

Definition Classes
VoidOChan → OChan
def close(t: UThread, a: Any, signal: Signal): Unit

Write last value
Write last value
a
the last value

Definition Classes
OChan
def close(t: UThread, seg: Seg[Any], signal: Signal): Unit

Write the last segment
Write the last segment
Note that this must flush any buffered channel (@see BufferedOChan).
seg
the last segment

Definition Classes
OChan
abstract def collect[B](pf: PartialFunction[B, Any]): OChan[B]

[use case] Builds a new output that applies a partial function to all messages on which the function is defined and filter out the others.
[use case]
Builds a new output that applies a partial function to all messages on which the function is defined and filter out the others.
B
the message type of the returned output channel.
pf
the partial function which filters and maps the stream elements.
returns
a new output resulting from applying the partial function pf to each message on which it is defined. The order of the messages is preserved.

Definition Classes
OChan
def collect[B](f: PartialFunction[B, Any])(implicit arg0: Message[B]): OChan[B]

Builds a new output that applies a partial function to all messages on which the function is defined and filter out the others.
Builds a new output that applies a partial function to all messages on which the function is defined and filter out the others.
B
the message type of the returned output channel.
returns
a new output resulting from applying the partial function pf to each message on which it is defined. The order of the messages is preserved.

Definition Classes
OChan
abstract def compress[B](f: (Seg[B]) ⇒ Any): OChan[B]

[use case] Builds a new output that applies a function to every segment written to it.
[use case]
Builds a new output that applies a function to every segment written to it.
B
the message type of the returned output.
f
the function to apply to each segment and returning a single message.
returns
a new output resulting from applying the given collection-valued function f to each segment written to it.

Definition Classes
OChan
def compress[B](f: (Seg[B]) ⇒ Any)(implicit arg0: Message[B]): OChan[B]

Builds a new output that applies a function to every segment written to it.
Builds a new output that applies a function to every segment written to it.
B
the message type of the returned output.
f
the function to apply to each segment and returning a single message.
returns
a new output resulting from applying the given collection-valued function f to each segment written to it.

Definition Classes
OChan
def debug[B <: Any](label: String, f: (B) ⇒ String)(implicit arg0: Message[B]): OChan[B]

Builds a new debugging output that prints every message received.
Builds a new debugging output that prints every message received.
label
the label to put in front of each debug line.
f
A function converting messages to a string (defaults to _.toString).
returns
The same output excepted each message will be printed.

Definition Classes
OChan
abstract def encode[B](f: (B) ⇒ Seg[Any]): OChan[B]

[use case] Builds a new output that applies a function to every messages written to it and concatenates the resulting segments.
[use case]
Builds a new output that applies a function to every messages written to it and concatenates the resulting segments.
B
the message type of the returned output.
f
the function to apply to each message and returning a segment.
returns
a new output resulting from applying the given collection-valued function f to each message written and concatenating the results.

Definition Classes
OChan
def encode[B](f: (B) ⇒ Seg[Any])(implicit arg0: Message[B]): OChan[B]

Builds a new output that applies a function to every messages written to it and concatenates the resulting segments.
Builds a new output that applies a function to every messages written to it and concatenates the resulting segments.
B
the message type of the returned output.
f
the function to apply to each message and returning a segment.
returns
a new output resulting from applying the given collection-valued function f to each message written and concatenating the results.

Definition Classes
OChan
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()
abstract def flatMap[B](f: (B) ⇒ Traversable[Any]): OChan[B]

[use case] Builds a new output that applies a function to all messages written to it and concatenates the results.
[use case]
Builds a new output that applies a function to all messages written to it and concatenates the results.
B
the message type of the returned output.
f
the function to apply to each message.
returns
a new output resulting from applying the given collection-valued function f to each message written and concatenating the results.

Definition Classes
OChan
def flatMap[B](f: (B) ⇒ Seg[Any])(implicit arg0: Message[B]): OChan[B]

Builds a new output that applies a function to all messages written to it and concatenates the results.
Builds a new output that applies a function to all messages written to it and concatenates the results.
B
the message type of the returned output.
f
the function to apply to each message.
returns
a new output resulting from applying the given collection-valued function f to each message written and concatenating the results.

Definition Classes
OChan
def flush[B <: Any](ichan: IChan[B]): Process[(IChan[B], OChan[B])]

Flush the content of an input to this output.
Flush the content of an input to this output. It stops as soon as one of the two channel is poisoned and it does not propagate the poison signal.
returns
A stream that returns the channels after the flush operation. If the stream completed successfully, then the input channel is closed, otherwise the output channel is poisoned.

Definition Classes
OChan
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
abstract def map[B](f: (B) ⇒ Any): OChan[B]

[use case] Builds a new output by applying a function to all the messages wrote to it.
[use case]
Builds a new output by applying a function to all the messages wrote to it.
B
the message type of the returned input.
f
the function to apply to each message.
returns
a new input resulting from applying the given function f to each message of this input.

Definition Classes
OChan
def map[B](f: (B) ⇒ Any)(implicit arg0: Message[B]): OChan[B]

Builds a new output by applying a function to all the messages wrote to it.
Builds a new output by applying a function to all the messages wrote to it.
B
the message type of the returned input.
f
the function to apply to each message.
returns
a new input resulting from applying the given function f to each message of this input.

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

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def parse[B](parse: Parser[B, Any])(implicit arg0: Message[B]): OChan[B]

Produces an output resulting from applying a repeatedly a parser combinator to its messages.
Produces an output resulting from applying a repeatedly a parser combinator to its messages.
B
the type of the messages of the resulting output
returns
output which parses its messages

Definition Classes
OChan
def smap[S, B](z: S)(fsm: (S, B) ⇒ (S, Any))(implicit arg0: Message[B]): OChan[B]

Builds an output producing cummulative results of applying the operator going from first to last message written.
Builds an output producing cummulative results of applying the operator going from first to last message written.
B
the type of the messages accepted by the resulting output
z
the initial state
returns
output producing intermediate results

Definition Classes
OChan
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()
def write(thread: UThread, seg: Seg[Any], sigOpt: Option[Signal], k: (OChan[Any]) ⇒ Unit): Unit

Write a segment on this channel.
Write a segment on this channel.
k
the continuation invoked once the message has been written

Definition Classes
VoidOChan → OChan

VoidOChan

object VoidOChan extends OChan[Any]

Value Members

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

abstract def :+:(seg: Seg[Any]): OChan[Any]

def :+:[B <: Any](seg: Seg[B])(implicit arg0: Message[B]): OChan[B]

abstract def :+:(x: Any): OChan[Any]

def :+:[B <: Any](x: B)(implicit arg0: Message[B]): OChan[B]

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

def add[B](transformer: (OChan[Any]) ⇒ OChan[B])(implicit arg0: Message[B]): OChan[B]

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def close(signal: Signal): Unit

def close(t: UThread, a: Any, signal: Signal): Unit

def close(t: UThread, seg: Seg[Any], signal: Signal): Unit

abstract def collect[B](pf: PartialFunction[B, Any]): OChan[B]

def collect[B](f: PartialFunction[B, Any])(implicit arg0: Message[B]): OChan[B]

abstract def compress[B](f: (Seg[B]) ⇒ Any): OChan[B]

def compress[B](f: (Seg[B]) ⇒ Any)(implicit arg0: Message[B]): OChan[B]

def debug[B <: Any](label: String, f: (B) ⇒ String)(implicit arg0: Message[B]): OChan[B]

abstract def encode[B](f: (B) ⇒ Seg[Any]): OChan[B]

def encode[B](f: (B) ⇒ Seg[Any])(implicit arg0: Message[B]): OChan[B]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

abstract def flatMap[B](f: (B) ⇒ Traversable[Any]): OChan[B]

def flatMap[B](f: (B) ⇒ Seg[Any])(implicit arg0: Message[B]): OChan[B]

def flush[B <: Any](ichan: IChan[B]): Process[(IChan[B], OChan[B])]

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

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

abstract def map[B](f: (B) ⇒ Any): OChan[B]

def map[B](f: (B) ⇒ Any)(implicit arg0: Message[B]): OChan[B]

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def parse[B](parse: Parser[B, Any])(implicit arg0: Message[B]): OChan[B]

def smap[S, B](z: S)(fsm: (S, B) ⇒ (S, Any))(implicit arg0: Message[B]): OChan[B]

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

def write(thread: UThread, seg: Seg[Any], sigOpt: Option[Signal], k: (OChan[Any]) ⇒ Unit): Unit

Inherited from OChan[Any]

Inherited from AnyRef

Inherited from Any