immutable

Type Members

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

   Adds a buffered segment to the head of a stream

2. case class CompressorT[A, B](complexity: Int, f: (Seg[B]) ⇒ A, evidence$1: Message[B]) extends (OChan[A]) ⇒ OChan[B] with Product with Serializable

3. class DebugT[A] extends (OChan[A]) ⇒ OChan[A]

4. case class FilterT[A](complexity: Int, p: (A) ⇒ Boolean, evidence$1: Message[A]) extends (OChan[A]) ⇒ OChan[A] with Product with Serializable

5. case class FlatMapperT[A, B](complexity: Int, f: (B) ⇒ Seg[A], evidence$1: Message[B]) extends (OChan[A]) ⇒ OChan[B] with Product with Serializable

6. case class FlatSegMapperT[A, B](complexity: Int, f: (B) ⇒ Seg[A], evidence$1: Message[B]) extends (OChan[A]) ⇒ OChan[B] with Product with Serializable

7. case class MapperT[A, B](complexity: Int, f: (B) ⇒ A, evidence$1: Message[B]) extends (OChan[A]) ⇒ OChan[B] with Product with Serializable

8. case class ParserT[A, B](complexity: Int, reset: Parser[B, A], parser: Parser[B, A], evidence$1: Message[B]) extends (OChan[A]) ⇒ OChan[B] with Product with Serializable

   Parse a ichan continuously

9. case class PartialMapperT[A, B](complexity: Int, f: PartialFunction[B, A], evidence$3: Message[B]) extends (OChan[A]) ⇒ OChan[B] with Product with Serializable

10. case class StateT[A, S, B](complexity: Int, state: S, fsm: (S, B) ⇒ (S, A), evidence$1: Message[B]) extends (OChan[A]) ⇒ OChan[B] with Product with Serializable

    Perform stateful operations on a ichan