Class/Object

lchannels

ActorOut

Related Docs: object ActorOut | package lchannels

Permalink

class ActorOut[-T] extends lchannels.medium.Out[Actor, T] with Serializable

Actor-based output channel endpoint, usually created through the companion object or via ActorChannel.factory.

Attributes
protected
Annotations
@SerialVersionUID()
Linear Supertypes
Serializable, Serializable, medium.Out[Actor, T], Out[T], Channel[Send], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ActorOut
  2. Serializable
  3. Serializable
  4. Out
  5. Out
  6. Channel
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ActorOut(bref: ActorRef[Value[T]])(implicit ec: ExecutionContext, as: ActorSystem)

    Permalink

Value Members

  1. def !(msg: T): Unit

    Permalink

    Alias for send.

    Alias for send.

    Definition Classes
    Out
  2. def !![U](f: (medium.Out[Actor, U]) ⇒ T): medium.In[Actor, U]

    Permalink

    Medium-constrained version of lchannels.Out.!!.

    Medium-constrained version of lchannels.Out.!!.

    Definition Classes
    Out
  3. def !![U](f: (medium.In[Actor, U]) ⇒ T): medium.Out[Actor, U]

    Permalink

    Medium-constrained version of lchannels.Out.!!.

    Medium-constrained version of lchannels.Out.!!.

    Definition Classes
    Out
  4. def !![U](f: (Out[U]) ⇒ T): In[U]

    Permalink

    Create a pair of U-typed channel endpoints (i,o), send the return value of f(o), and return i.

    Create a pair of U-typed channel endpoints (i,o), send the return value of f(o), and return i.

    This method automates channel creation in continuation-passing-style protocols, when the output endpoint must be sent as part of a T-typed message (as returned by f(i)), and the input endpoint is later used to continue the interaction.

    f

    Function that, when applied to an output channel endpoint, returns the message to be sent.

    Definition Classes
    Out
  5. def !![U](f: (In[U]) ⇒ T): Out[U]

    Permalink

    Create a pair of U-typed channel endpoints (i,o), send the return value of f(i), and return o.

    Create a pair of U-typed channel endpoints (i,o), send the return value of f(i), and return o.

    This method automates channel creation in continuation-passing-style protocols, when the input endpoint must be sent as part of a T-typed message (as returned by f(i)), and the output endpoint is later used to continue the interaction.

    f

    Function that, when applied to an input channel endpoint, returns the message to be sent.

    Definition Classes
    Out
  6. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  7. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  8. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  9. final def _markAsUsed(): Unit

    Permalink
    Attributes
    protected
  10. implicit val as: ActorSystem

    Permalink
  11. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  12. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. def create[U](): (ActorIn[U], ActorOut[U])

    Permalink

    Return a pair of input/output linear channel endpoints

    Return a pair of input/output linear channel endpoints

    Definition Classes
    ActorOutOutOut
  14. def createContIn[U](): (medium.In[Actor, U], medium.Out[Actor, U])

    Permalink

    Medium-constrained version of lchannels.Out.createContIn.

    Medium-constrained version of lchannels.Out.createContIn.

    Definition Classes
    OutOut
  15. def createContOut[U](): (medium.In[Actor, U], medium.Out[Actor, U])

    Permalink

    Medium-constrained version of lchannels.Out.createContOut.

    Medium-constrained version of lchannels.Out.createContOut.

    Definition Classes
    OutOut
  16. implicit val ec: ExecutionContext

    Permalink
  17. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  18. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  19. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  20. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  21. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  22. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  23. final def markAsUsed(): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Channel
  24. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  25. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  26. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  27. def path: ActorPath

    Permalink

    Return the path of the Akka actor giving access to the channel endpoint

    Return the path of the Akka actor giving access to the channel endpoint

    The path allows to (remotely) proxy the channel endpoint, via ActorOut$.apply.

  28. def promise[U <: T]: Promise[U]

    Permalink

    Return a promise that, once completed with a value v, causes v to be sent along this channel endpoint.

    Return a promise that, once completed with a value v, causes v to be sent along this channel endpoint.

    Definition Classes
    Out
  29. def send(v: T): Unit

    Permalink

    Send a message.

    Send a message.

    Definition Classes
    ActorOutOut
    Exceptions thrown

    AlreadyUsed if the channel endpoint was already used for output

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

    Permalink
    Definition Classes
    AnyRef
  31. def toString(): String

    Permalink
    Definition Classes
    ActorOut → AnyRef → Any
  32. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  34. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from medium.Out[Actor, T]

Inherited from Out[T]

Inherited from Channel[Send]

Inherited from AnyRef

Inherited from Any

Ungrouped