Packages

  • package root
    Definition Classes
    root
  • package fs2
    Definition Classes
    root
  • package io

    Provides various ways to work with streams that perform IO.

    Provides various ways to work with streams that perform IO.

    These methods accept a blocking ExecutionContext, as the underlying implementations perform blocking IO. The recommendation is to use an unbounded thread pool with application level bounds.

    Definition Classes
    fs2
    See also

    https://typelevel.org/cats-effect/concurrency/basics.html#blocking-threads

  • package file

    Provides support for working with files.

    Provides support for working with files.

    Definition Classes
    io
  • package tcp

    Provides support for TCP networking.

    Provides support for TCP networking.

    Definition Classes
    io
  • Socket
  • package udp

    Provides support for UDP networking.

    Provides support for UDP networking.

    Definition Classes
    io
p

fs2.io

tcp

package tcp

Provides support for TCP networking.

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

Type Members

  1. trait Socket[F[_]] extends AnyRef

    Provides the ability to read/write from a TCP socket in the effect F.

    Provides the ability to read/write from a TCP socket in the effect F.

    To construct a Socket, use the methods in the fs2.io.tcp package object.

Value Members

  1. object Socket

Deprecated Value Members

  1. 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: ConcurrentEffect[F]): Resource[F, Socket[F]]
    Annotations
    @deprecated
    Deprecated

    (Since version 1.0.1) Use fs2.io.tcp.Socket.client

  2. def server[F[_]](bind: InetSocketAddress, maxQueued: Int = 0, reuseAddress: Boolean = true, receiveBufferSize: Int = 256 * 1024)(implicit AG: AsynchronousChannelGroup, F: ConcurrentEffect[F]): Stream[F, Resource[F, Socket[F]]]
    Annotations
    @deprecated
    Deprecated

    (Since version 1.0.1) Use fs2.io.tcp.Socket.server

  3. def serverWithLocalAddress[F[_]](bind: InetSocketAddress, maxQueued: Int = 0, reuseAddress: Boolean = true, receiveBufferSize: Int = 256 * 1024)(implicit AG: AsynchronousChannelGroup, F: ConcurrentEffect[F]): Stream[F, Either[InetSocketAddress, Resource[F, Socket[F]]]]
    Annotations
    @deprecated
    Deprecated

    (Since version 1.0.1) Use fs2.io.tcp.Socket.serverWithLocalAddress

Inherited from AnyRef

Inherited from Any

Ungrouped