package udp
- Alphabetic
- By Inheritance
- udp
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
sealed
trait
AsynchronousSocketGroup
extends AnyRef
Supports read/write operations on an arbitrary number of UDP sockets using a shared selector thread.
Supports read/write operations on an arbitrary number of UDP sockets using a shared selector thread.
Each
AsynchronousSocketGroupis assigned a single daemon thread that performs all read/write operations. -
final
case class
Packet
(remote: InetSocketAddress, bytes: Chunk[Byte]) extends Product with Serializable
A single packet to send to the specified remote address or received from the specified address.
A single packet to send to the specified remote address or received from the specified address.
- remote
remote party to send/receive packet to/from
- bytes
data to send/receive
-
sealed
trait
Socket
[F[_]] extends AnyRef
Provides the ability to read/write from a UDP socket in the effect
F.Provides the ability to read/write from a UDP socket in the effect
F.To construct a
Socket, use the methods in the fs2.io.udp package object.
Value Members
-
def
open[F[_]](address: InetSocketAddress = new InetSocketAddress(0), reuseAddress: Boolean = false, sendBufferSize: Option[Int] = None, receiveBufferSize: Option[Int] = None, allowBroadcast: Boolean = true, protocolFamily: Option[ProtocolFamily] = None, multicastInterface: Option[NetworkInterface] = None, multicastTTL: Option[Int] = None, multicastLoopback: Boolean = true)(implicit AG: AsynchronousSocketGroup, F: Async[F]): Stream[F, Socket[F]]
Provides a singleton stream of a UDP Socket that, when run, will bind to the specified adress.
Provides a singleton stream of a UDP Socket that, when run, will bind to the specified adress.
- address
address to bind to; defaults to an ephemeral port on all interfaces
- reuseAddress
whether address has to 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)- allowBroadcast
whether broadcast messages are allowed to be sent; defaults to true
- protocolFamily
protocol family to use when opening the supporting
DatagramChannel- multicastInterface
network interface for sending multicast packets
- multicastTTL
time to live of sent multicast packets
- multicastLoopback
whether sent multicast packets should be looped back to this host
- object AsynchronousSocketGroup