SocketOut

Instance Constructors

new SocketOut(sktm: SocketManager)

Value Members

def !(msg: T): Unit

Alias for send.
Alias for send.

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

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

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

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

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

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
def !![U](f: (In[U]) ⇒ T): Out[U]

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
final def !=(arg0: Any): Boolean

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

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

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def create[U](): (SocketIn[U], SocketOut[U])

Return a pair of input/output linear channel endpoints
Return a pair of input/output linear channel endpoints

Definition Classes
SocketOut → Out → Out
def createContIn[U](): (medium.In[Socket, U], medium.Out[Socket, U])

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

Definition Classes
Out → Out
def createContOut[U](): (medium.In[Socket, U], medium.Out[Socket, U])

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

Definition Classes
Out → Out
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

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

Definition Classes
AnyRef → Any
def hashCode(): Int

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

Definition Classes
Any
final def markAsUsed(): Unit

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

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def promise[U <: T]: Promise[U]

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
def send(x: T): Unit

Send a message.
Send a message.

Definition Classes
SocketOut → Out
Exceptions thrown
AlreadyUsed if the channel endpoint was already used for output
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: object SocketOut | package lchannels

class SocketOut[-T] extends lchannels.medium.Out[Socket, T]

Instance Constructors

new SocketOut(sktm: SocketManager)

Value Members

def !(msg: T): Unit

def !![U](f: (medium.Out[Socket, U]) ⇒ T): medium.In[Socket, U]

def !![U](f: (medium.In[Socket, U]) ⇒ T): medium.Out[Socket, U]

def !![U](f: (Out[U]) ⇒ T): In[U]

def !![U](f: (In[U]) ⇒ T): Out[U]

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def create[U](): (SocketIn[U], SocketOut[U])

def createContIn[U](): (medium.In[Socket, U], medium.Out[Socket, U])

def createContOut[U](): (medium.In[Socket, U], medium.Out[Socket, U])

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def markAsUsed(): Unit

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

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

def send(x: T): Unit

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

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from medium.Out[Socket, T]

Inherited from Out[T]

Inherited from Channel[Send]

Inherited from AnyRef

Inherited from Any

Ungrouped