Value Members

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

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def client[F[_]](to: InetSocketAddress, reuseAddress: Boolean = true, sendBufferSize: Int = 256 * 1024, receiveBufferSize: Int = 256 * 1024, keepAlive: Boolean = false, noDelay: Boolean = false)(implicit AG: AsynchronousChannelGroup, F: Concurrent[F], CS: ContextShift[F]): Resource[F, Socket[F]]

   Stream that connects to the specified server and emits a single socket, allowing reads/writes via operations on the socket.

   Stream that connects to the specified server and emits a single socket, allowing reads/writes via operations on the socket. The socket is closed when the outer stream terminates.

   to

   address of remote server

   reuseAddress

   whether address may be reused (see java.net.StandardSocketOptions.SO_REUSEADDR)

   sendBufferSize

   size of send buffer (see java.net.StandardSocketOptions.SO_SNDBUF)

   receiveBufferSize

   size of receive buffer (see java.net.StandardSocketOptions.SO_RCVBUF)

   keepAlive

   whether keep-alive on tcp is used (see java.net.StandardSocketOptions.SO_KEEPALIVE)

   noDelay

   whether tcp no-delay flag is set (see java.net.StandardSocketOptions.TCP_NODELAY)

6.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @native() @throws( ... )

7.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

8.  def equals(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

9.  def finalize(): Unit

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( classOf[java.lang.Throwable] )

10.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

11.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

12.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

13.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

14.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

15.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

16.  def server[F[_]](address: InetSocketAddress, maxQueued: Int = 0, reuseAddress: Boolean = true, receiveBufferSize: Int = 256 * 1024)(implicit AG: AsynchronousChannelGroup, F: Concurrent[F], CS: ContextShift[F]): Stream[F, Resource[F, Socket[F]]]

    Stream that binds to the specified address and provides a connection for, represented as a Socket, for each client that connects to the bound address.

    Stream that binds to the specified address and provides a connection for, represented as a Socket, for each client that connects to the bound address.

    Returns a stream of stream of sockets.

    The outer stream scopes the lifetime of the server socket. When the outer stream terminates, all open connections will terminate as well. The outer stream emits an element (an inner stream) for each client connection.

    Each inner stream represents an individual connection, and as such, is a stream that emits a single socket. Failures that occur in an inner stream do *NOT* cause the outer stream to fail.

    address

    address to accept connections from

    maxQueued

    number of queued requests before they will become rejected by server (supply <= 0 for unbounded)

    reuseAddress

    whether address may be reused (see java.net.StandardSocketOptions.SO_REUSEADDR)

    receiveBufferSize

    size of receive buffer (see java.net.StandardSocketOptions.SO_RCVBUF)

17.  def serverWithLocalAddress[F[_]](address: InetSocketAddress, maxQueued: Int = 0, reuseAddress: Boolean = true, receiveBufferSize: Int = 256 * 1024)(implicit AG: AsynchronousChannelGroup, F: Concurrent[F], CS: ContextShift[F]): Stream[F, Either[InetSocketAddress, Resource[F, Socket[F]]]]

    Like server but provides the InetSocketAddress of the bound server socket before providing accepted sockets.

    Like server but provides the InetSocketAddress of the bound server socket before providing accepted sockets.

    The outer stream first emits a left value specifying the bound address followed by right values -- one per client connection.

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

    Definition Classes

    AnyRef

19.  def toString(): String

    Definition Classes

    AnyRef → Any

20.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

22.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )