UdpClient.java 文件源码

/**
 * Create a {@link ContextHandler} for {@link Bootstrap#handler()}
 *
 * @param handler user provided in/out handler
 * @param sink user provided bind handler
 *
 * @return a new {@link ContextHandler}
 */
protected ContextHandler<DatagramChannel> doHandler(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>> handler,
        MonoSink<NettyContext> sink,
        SocketAddress providedAddress) {
    return ContextHandler.newClientContext(sink,
            options,
            loggingHandler,
            false,
            providedAddress,
            (ch, c, msg) -> UdpOperations.bind(ch, handler, c));
}