molecule.stream.ochan

BufferedOChan

case class BufferedOChan[A](seg: Seg[A], next: OChan[A], evidence$1: Message[A]) extends OChan[A] with Product with Serializable

Source
BufferedOChan.scala
Linear Supertypes
Serializable, Serializable, Product, Equals, OChan[A], AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. BufferedOChan
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. OChan
  7. AnyRef
  8. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new BufferedOChan(seg: Seg[A], next: OChan[A])(implicit arg0: Message[A])

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. abstract def :+:(seg: Seg[A]): OChan[A]

    [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

  5. def :+:[B <: A](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

  6. abstract def :+:(x: A): OChan[A]

    [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

  7. def :+:[B <: A](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

  8. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  9. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  10. def add[B](transformer: (OChan[A]) ⇒ 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
    BufferedOChan → OChan

  11. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  12. def canEqual(arg0: Any): Boolean

    Definition Classes
    BufferedOChan → Equals

  13. def clone(): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  14. def close(signal: Signal): Unit

    Close the channel

    Close the channel

    Definition Classes
    BufferedOChan → OChan

  15. def close(t: UThread, a: A, signal: Signal): Unit

    Write last value

    Write last value

    a

    the last value

    Definition Classes
    OChan

  16. def close(t: UThread, seg: Seg[A], 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

  17. abstract def collect[B](pf: PartialFunction[B, A]): 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

  18. def collect[B](f: PartialFunction[B, A])(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

  19. abstract def compress[B](f: (Seg[B]) ⇒ A): 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

  20. def compress[B](f: (Seg[B]) ⇒ A)(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

  21. def debug[B <: A](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

  22. abstract def encode[B](f: (B) ⇒ Seg[A]): 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

  23. def encode[B](f: (B) ⇒ Seg[A])(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

  24. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  25. def equals(arg0: Any): Boolean

    Definition Classes
    BufferedOChan → Equals → AnyRef → Any

  26. def finalize(): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  27. abstract def flatMap[B](f: (B) ⇒ Traversable[A]): 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

  28. def flatMap[B](f: (B) ⇒ Seg[A])(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

  29. def flush[B <: A](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

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

    Definition Classes
    AnyRef → Any

  31. def hashCode(): Int

    Definition Classes
    BufferedOChan → AnyRef → Any

  32. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  33. abstract def map[B](f: (B) ⇒ A): 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

  34. def map[B](f: (B) ⇒ A)(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

  35. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  36. val next: OChan[A]

  37. final def notify(): Unit

    Definition Classes
    AnyRef

  38. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  39. def parse[B](parse: Parser[B, A])(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

  40. def productArity: Int

    Definition Classes
    BufferedOChan → Product

  41. def productElement(arg0: Int): Any

    Definition Classes
    BufferedOChan → Product

  42. def productIterator: Iterator[Any]

    Definition Classes
    Product

  43. def productPrefix: String

    Definition Classes
    BufferedOChan → Product

  44. val seg: Seg[A]

  45. def smap[S, B](z: S)(fsm: (S, B) ⇒ (S, A))(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

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

    Definition Classes
    AnyRef

  47. def toString(): String

    Definition Classes
    BufferedOChan → AnyRef → Any

  48. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

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

    Definition Classes
    AnyRef
    Annotations
    @throws()

  50. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  51. def write(t: UThread, seg: Seg[A], sigOpt: Option[Signal], k: (OChan[A]) ⇒ Unit): Unit

    Write a segment on this channel.

    Write a segment on this channel.

    t

    the user-level thread

    k

    the continuation invoked once the message has been written

    Definition Classes
    BufferedOChan → OChan

Deprecated Value Members

  1. def productElements: Iterator[Any]

    Definition Classes
    Product
    Annotations
    @deprecated
    Deprecated

    (Since version 2.8.0) use productIterator instead

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from OChan[A]

Inherited from AnyRef

Inherited from Any