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
TcpResources.java
TcpServerHandle.java
package-info.java
TcpServerOperator.java
TcpServerObserve.java
TcpServerRunOn.java
TcpServerUnsecure.java
TcpServerDoOnConnection.java
TcpClient.java
TcpServer.java
TcpUtils.java
TcpClientUnsecure.java
TcpServerBind.java
TcpClientProxy.java
TcpClientSecure.java
TcpClientBootstrap.java
InetSocketAddressUtil.java
TcpServerDoOn.java
TcpServerSecure.java
ProxyProvider.java
TcpClientDoOn.java
TcpClientRunOn.java
TcpServerBootstrap.java
TcpClientUnproxy.java
TcpClientOperator.java
TcpClientObserve.java
TcpClientConnect.java
SslProvider.java
udp
NettyInbound.java
channel
ReactorNetty.java
ChannelBindException.java
DisposableServer.java
FutureMono.java
NettyOutbound.java
TcpClientProxy.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.tcp; import java.util.
Objects
; import java.util.function.
Consumer
; import io.netty.bootstrap.
Bootstrap
; /** * @author Stephane Maldini */ final class
TcpClientProxy
extends
TcpClientOperator
{ final
ProxyProvider
proxyProvider
;
TcpClientProxy
(
TcpClient
client
,
Consumer
<? super
ProxyProvider
.
TypeSpec
>
proxyOptions
) { super(
client
);
Objects
.
requireNonNull
(
proxyOptions
, "proxyOptions");
ProxyProvider
.
Build
builder
= (
ProxyProvider
.
Build
)
ProxyProvider
.
builder
();
proxyOptions
.
accept
(
builder
); this.
proxyProvider
=
builder
.
build
(); } @
Override
@
SuppressWarnings
("unchecked") public
Bootstrap
configure
() { return
TcpUtils
.
updateProxySupport
(
source
.
configure
(),
proxyProvider
); } @
Override
public
ProxyProvider
proxyProvider
() { return this.
proxyProvider
; } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口