molecule.request

core

package core

Implicit definitions for using request-response protocols in a reactive style.

Visibility
  1. Public
  2. All

Type Members

  1. class NativeRequestChannel[A] extends AnyRef

    Enrich channels supporting request-response protocols for easily sending request messages using a native thread.

  2. class RequestChannel[A] extends AnyRef

    Enrich output channels supporting request-response protocols for easily sending request messages

  3. case class RequestSignal(ochan: molecule.stream.OChan[_], signal: Signal) extends Signal with Product with Serializable

  4. class RichResponseChannel[A] extends AnyRef

    Enrich response channels.

Value Members

  1. implicit def enrichNativeRequestChannel[A](ochan: NativeProducer[A]): NativeRequestChannel[A]

    Enrich channels supporting multiple protocols for easily sending request messages in a native manner

    Enrich channels supporting multiple protocols for easily sending request messages in a native manner

    Definition Classes
    package

  2. implicit def enrichRequestChannel[A](ochan: OChan[A]): RequestChannel[A]

    Enrich output channels supporting multiple protocols for easily sending request messages

    Enrich output channels supporting multiple protocols for easily sending request messages

    Definition Classes
    package

  3. implicit def enrichResponseChannel[A](rchan: ResponseChannel[A]): RichResponseChannel[A]

    Enrich output channels supporting multiple protocols for easily sending request messages

    Enrich output channels supporting multiple protocols for easily sending request messages

    Definition Classes
    package