Top Description Fields Constructors Methods
reactor.netty.udp

pack-priv final Class UdpOperations

extends ChannelOperations<UdpInbound, UdpOutbound>
implements UdpInbound, UdpOutbound
Class Inheritance
All Implemented Interfaces
reactor.netty.udp.UdpOutbound, reactor.netty.NettyOutbound, org.reactivestreams.Publisher, reactor.netty.udp.UdpConnection, reactor.netty.udp.UdpInbound, reactor.netty.NettyInbound
Imports
java.net.InetAddress, .InetSocketAddress, .NetworkInterface, io.netty.channel.ChannelFuture, io.netty.channel.socket.DatagramChannel, org.reactivestreams.Publisher, reactor.core.publisher.Mono, reactor.netty.Connection, .ConnectionObserver, .FutureMono, reactor.netty.channel.ChannelOperations, reactor.util.Logger, .Loggers, reactor.util.annotation.Nullable
UdpInbound and UdpOutbound that apply to a Connection.
Author
Stephane Maldini

Field Summary

Modifier and TypeField and Description
pack-priv static final Logger
log

Hides reactor.netty.channel.ChannelOperations.log.

Constructor Summary

AccessConstructor and Description
pack-priv
UdpOperations(Connection c, ConnectionObserver listener)

Method Summary

Modifier and TypeMethod and Description
public Mono<Void>

Returns:

a Publisher that will be complete when the group has been joined
join(final InetAddress
multicast address of the group to join
multicastAddress, NetworkInterface iface)

Implements reactor.netty.udp.UdpConnection.join.

Join a multicast group.
public Mono<Void>

Returns:

a Publisher that will be complete when the group has been left
leave(final InetAddress
multicast address of the group to leave
multicastAddress, NetworkInterface iface)

Implements reactor.netty.udp.UdpConnection.leave.

Leave a multicast group.
Inherited from reactor.netty.channel.ChannelOperations:
addMetricsHandleraddReactiveBridgeafterInboundCompleteallocasasDebugLogMessageasLongTextasShortTextchannelconnectioncurrentContextdiscarddiscardWhenNoReceiverdisposedisposeSubscriberformatNamegetinboundinitShortIdisDisposedisInboundCancelledisInboundCompleteisInboundDisposedisPersistentisSubscriptionDisposedlisteneronCompleteonDisposeonDisposeonErroronInboundCancelonInboundCloseonInboundCompleteonInboundErroronInboundNextonNextonOutboundCompleteonOutboundErroronSubscribeonTerminateonUnprocessedOutboundErroronWritabilityChangedoutboundreceivereceiveObjectsendsendObjectsendObjectsendUsingterminatetoStringwithConnectionwrapInboundError

Field Detail

logback to summary
pack-priv static final Logger log

Hides reactor.netty.channel.ChannelOperations.log.

Constructor Detail

UdpOperationsback to summary
pack-priv UdpOperations(Connection c, ConnectionObserver listener)

Method Detail

joinback to summary
public Mono<Void> join(final InetAddress multicastAddress, NetworkInterface iface)

Implements reactor.netty.udp.UdpConnection.join.

Join a multicast group.

Parameters
multicastAddress:InetAddress

multicast address of the group to join

Returns:Mono<Void>

a Publisher that will be complete when the group has been joined

Annotations
@Override
leaveback to summary
public Mono<Void> leave(final InetAddress multicastAddress, NetworkInterface iface)

Implements reactor.netty.udp.UdpConnection.leave.

Leave a multicast group.

Parameters
multicastAddress:InetAddress

multicast address of the group to leave

Returns:Mono<Void>

a Publisher that will be complete when the group has been left

Annotations
@Override