Class

lchannels

SocketManager

Related Doc: package lchannels

Permalink

abstract class SocketManager extends AnyRef

Base class for socket management and (de)serialization of messages.

This class assumes to have exclusive control over the given socket.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SocketManager
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SocketManager(socket: java.net.Socket)

    Permalink

    socket

    Socket for sending/receiving data

Abstract Value Members

  1. abstract def destreamer(): Any

    Permalink

    Read data from in, deserialize an object and return it.

    Read data from in, deserialize an object and return it.

    Exceptions thrown

    Exception if a deserialization error occurs.

  2. abstract def streamer(x: Any): Unit

    Permalink

    Serialize an object and write it into out.

    Serialize an object and write it into out.

    x

    Object to serialize.

Concrete Value Members

  1. final def !=(arg0: Any): Boolean

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

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

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

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

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  6. def close(): Unit

    Permalink

    Close the socket.

    Close the socket.

    You could derive this method to perform additional cleanup when closing the StreamManager.

  7. final def destreamer(atMost: Duration): Any

    Permalink

    Read data from in, deserialize an object and return it.

    Read data from in, deserialize an object and return it.

    atMost

    Maximum wait time

    Attributes
    protected[lchannels]
    Exceptions thrown

    Exception if a deserialization error occurs.

    java.util.concurrent.TimeoutException if after waiting for atMost, no message arrives

  8. final def eq(arg0: AnyRef): Boolean

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

    Permalink
    Definition Classes
    AnyRef → Any
  10. def factory[T](): (SocketIn[T], SocketOut[T])

    Permalink

    Create a pair of I/O socket-based channel endpoints, reading from in and writing to out.

  11. final def finalize(): Unit

    Permalink

    Alias for close.

    Alias for close.

    Definition Classes
    SocketManager → AnyRef
  12. final def getClass(): Class[_]

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

    Permalink
    Definition Classes
    AnyRef → Any
  14. val in: InputStream

    Permalink

    The InputStream of socket.

    The InputStream of socket.

    Attributes
    protected
  15. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  16. final def ne(arg0: AnyRef): Boolean

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

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

    Permalink
    Definition Classes
    AnyRef
  19. val out: OutputStream

    Permalink

    The OutputStream of socket.

    The OutputStream of socket.

    Attributes
    protected
  20. final def synchronized[T0](arg0: ⇒ T0): T0

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

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

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

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

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

Inherited from AnyRef

Inherited from Any

Ungrouped