molecule.stream

ichan

package ichan

Visibility
  1. Public
  2. All

Type Members

  1. final class BackIChan[A] extends IChan[A]

    First-class channel that reschedules the continuation of a system-level channel inside its user-level thread.

  2. class DelayedIChan[A] extends IChan[A]

  3. final class FrontIChan[A] extends IChan[A]

    A front channel has two roles: - monitors the complexity of channel transformations and schedules the new channel operations on a thread pool if the complexity becomes too high.

  4. class NilIChan extends IChan[Nothing] with TestableIChan[Nothing]

  5. trait StatefulIChan[+S, +B] extends IChan[B]

    IChan that contains some state S

  6. trait TestableIChan[+A] extends IChan[A]

    IChan that can be tested for the availability of data in memory.

  7. type Transformer[A, B] = (IChan[A]) ⇒ IChan[B]

    Definition Classes
    package
  8. type UThread = UThread

    Definition Classes
    package

Value Members

  1. object BackIChan extends AnyRef

  2. object CombineUtils extends AnyRef

  3. object FrontIChan extends AnyRef

  4. object NilIChan extends AnyRef

  5. package immutable

  6. package mutable