molecule

channel

package channel

This package contains standard channels to interact with standard input/output and connect Molecule processes. These channels implement the interfaces defined in the package syschan.

Visibility
  1. Public
  2. All

Type Members

  1. case class ChannelOverflowSignal(id: String, capacity: Int) extends Signal with Product with Serializable

    Signal sent when the capacity of an asynchronous channel is exceeded and all other fallback mechanisms have been exhausted.

  2. final class ConcurrentReadException extends Error

  3. final class ConcurrentWriteException extends Error

    Standard exceptions that might be thrown by system-level channels.

  4. trait GetChan[+A] extends AnyRef

    Trait for blocking system-level input channels with blocking and message-at-a-time semantics.

  5. trait IChan[+A] extends AnyRef

    Trait for non-blocking system-level input channels.

  6. trait NativeConsumer[+A] extends AnyRef

    A NativeConsumer interface permits to consume messages in a blocking manner from a native thread.

  7. abstract class NativeProducer[-A] extends AnyRef

    A NativeProducer interfaces permits to produce messages in a blocking manner from a native thread.

  8. trait OChan[-A] extends AnyRef

    Trait for non-blocking system-level output channels.

  9. class OChanFactory[-A] extends () ⇒ OChan[A]

    A factory for output channels.

  10. trait Predefs extends AnyRef

  11. trait PutChan[-A] extends AnyRef

    Trait for blocking system-level output channels.

  12. abstract class RIChan[+A] extends IChan[A]

    "Result", "reply" or "response" input channel interface.

  13. abstract class ROChan[-A] extends AnyRef

    "Result", "reply" or "response" output channel interface.

Value Members

  1. object Buffer extends AnyRef

    Factory for cooperative buffered channels.

  2. object Chan extends AnyRef

    Factory for in-memory cooperative (aka rendez-vous) channels

  3. object Clock extends AnyRef

  4. object Console extends AnyRef

  5. object GetChan extends AnyRef

  6. object IChan extends AnyRef

  7. object ManyToOne extends AnyRef

    Factory for multiple-producers, single-consumer cooperative channels

  8. object NativeConsumer extends AnyRef

  9. object NativeProducer extends AnyRef

  10. object OChan extends AnyRef

  11. object OChanFactory extends AnyRef

    Factory object for output channel factories.

  12. object PutChan extends AnyRef

  13. object RChan extends AnyRef

    Companion factory object for RChan

  14. object RIChan extends AnyRef

    Factory methods for RIChan and extra DSL support like callcc and parl (see ChameneosRedux example in molecule-core-examples).

  15. object ROChan extends AnyRef

    Companion object for ROChan

  16. object Timer extends AnyRef

    A timer channel schedules time events on its output using the platform's internal timers facilities.