reactor-netty-0.8.0.RELEASE.jar
登录
|
io.projectreactor.netty:reactor-netty:0.8.0.RELEASE
META-INF
reactor
netty
ConnectionObserver.java
package-info.java
ByteBufFlux.java
http
DisposableChannel.java
NettyPipeline.java
Connection.java
ByteBufMono.java
resources
tcp
udp
UdpClientObserve.java
UdpClientOperator.java
UdpClientRunOn.java
package-info.java
UdpClientConnect.java
UdpOutbound.java
UdpClientDoOn.java
UdpServerRunOn.java
UdpClient.java
UdpResources.java
UdpServerBind.java
UdpOperations.java
UdpServerOperator.java
UdpServerBootstrap.java
UdpInbound.java
UdpClientBootstrap.java
UdpServerDoOn.java
UdpConnection.java
UdpServerObserve.java
UdpServer.java
NettyInbound.java
channel
ReactorNetty.java
ChannelBindException.java
DisposableServer.java
FutureMono.java
NettyOutbound.java
UdpClientRunOn.java
清空
类结构
/* * Copyright (c) 2011-2018 Pivotal Software Inc, All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package reactor.netty.udp; import java.util.
Objects
; import javax.annotation.
Nullable
; import io.netty.bootstrap.
Bootstrap
; import io.netty.channel.
EventLoopGroup
; import io.netty.channel.socket.
InternetProtocolFamily
; import io.netty.channel.socket.nio.
NioDatagramChannel
; import reactor.netty.resources.
LoopResources
; /** * @author Stephane Maldini */ final class
UdpClientRunOn
extends
UdpClientOperator
{ final
LoopResources
loopResources
; final boolean
preferNative
; final
InternetProtocolFamily
family
;
UdpClientRunOn
(
UdpClient
server
,
LoopResources
loopResources
, boolean
preferNative
, @
Nullable
InternetProtocolFamily
family
) { super(
server
); this.
loopResources
=
Objects
.
requireNonNull
(
loopResources
, "loopResources"); this.
preferNative
=
preferNative
; this.
family
=
family
; } @
Override
protected
Bootstrap
configure
() {
Bootstrap
b
=
source
.
configure
(); boolean
useNative
=
family
== null &&
preferNative
;
EventLoopGroup
elg
=
loopResources
.
onClient
(
useNative
); if (
useNative
) {
b
.
channel
(
loopResources
.
onDatagramChannel
(
elg
)); } else {
b
.
channelFactory
(() -> new
NioDatagramChannel
(
family
)); } return
b
.
group
(
elg
); } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口