Java NettyContext类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中reactor.ipc.netty.NettyContext类的典型用法代码示例。如果您正苦于以下问题：Java NettyContext类的具体用法？Java NettyContext怎么用？Java NettyContext使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

NettyContext类属于reactor.ipc.netty包，在下文中一共展示了NettyContext类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: newHandler

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Override
public Mono<? extends NettyContext> newHandler(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>> handler) {
	final BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>
			targetHandler =
			null == handler ? ChannelOperations.noopHandler() : handler;

	return Mono.create(sink -> {
		Bootstrap b = options.get();
		SocketAddress adr = options.getAddress();
		if(adr == null){
			sink.error(new NullPointerException("Provided UdpServerOptions do not " +
					"define any address to bind to "));
			return;
		}
		b.localAddress(adr);
		ContextHandler<DatagramChannel> c = doHandler(targetHandler, sink, adr);
		b.handler(c);
		c.setFuture(b.bind());
	});
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:21，代码来源:UdpServer.java

示例2: newHandler

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Override
public Mono<? extends NettyContext> newHandler(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>> handler) {
	final BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>
			targetHandler =
			null == handler ? ChannelOperations.noopHandler() : handler;

	return Mono.create(sink -> {
		Bootstrap b = options.get();
		SocketAddress adr = options.getAddress();
		if(adr == null){
			sink.error(new NullPointerException("Provided UdpClientOptions do not " +
					"define any address to bind to "));
			return;
		}
		b.remoteAddress(adr);
		ContextHandler<DatagramChannel> c = doHandler(targetHandler, sink, adr);
		b.handler(c);
		c.setFuture(b.connect());
	});
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:21，代码来源:UdpClient.java

示例3: newClientContext

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
/**
 * Create a new client context
 *
 * @param sink
 * @param options
 * @param loggingHandler
 * @param secure
 * @param channelOpFactory
 * @param <CHANNEL>
 *
 * @return a new {@link ContextHandler} for clients
 */
public static <CHANNEL extends Channel> ContextHandler<CHANNEL> newClientContext(
		MonoSink<NettyContext> sink,
		ClientOptions options,
		LoggingHandler loggingHandler,
		boolean secure,
		SocketAddress providedAddress,
		ChannelOperations.OnNew<CHANNEL> channelOpFactory) {
	return newClientContext(sink,
			options,
			loggingHandler,
			secure,
			providedAddress,
			null,
			channelOpFactory);
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:28，代码来源:ContextHandler.java

示例4: ContextHandler

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
/**
 * @param channelOpFactory
 * @param options
 * @param sink
 * @param loggingHandler
 * @param providedAddress the {@link InetSocketAddress} targeted by the operation
 * associated with that handler (useable eg. for SNI), or null if unavailable.
 */
@SuppressWarnings("unchecked")
protected ContextHandler(ChannelOperations.OnNew<CHANNEL> channelOpFactory,
		NettyOptions<?, ?> options,
		MonoSink<NettyContext> sink,
		LoggingHandler loggingHandler,
		SocketAddress providedAddress) {
	this.channelOpFactory =
			Objects.requireNonNull(channelOpFactory, "channelOpFactory");
	this.options = options;
	this.sink = sink;
	this.loggingHandler = loggingHandler;
	this.autoCreateOperations = true;
	this.providedAddress = providedAddress;

}

开发者ID:reactor，项目名称:reactor-netty，代码行数:24，代码来源:ContextHandler.java

示例5: release

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
final void release(CHANNEL c) {
	if (log.isDebugEnabled()) {
		log.debug("Releasing channel: {}", c.toString());
	}

	if (!NettyContext.isPersistent(c) && c.isActive()) {
		c.close();
	}

	pool.release(c)
	    .addListener(f -> {
		    if (f.isSuccess()) {
			    onReleaseEmitter.onComplete();
		    }
		    else {
			    onReleaseEmitter.onError(f.cause());
		    }
	    });

}

开发者ID:reactor，项目名称:reactor-netty，代码行数:21，代码来源:PooledClientContextHandler.java

示例6: preparePipeline

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
/**
 * {@inheritDoc}
 * <p>
 * This adds a ChunkedWriter to the pipeline to extract chunks from the
 * {@link io.netty.handler.stream.ChunkedInput} that the strategy produces. This step
 * is skipped if the handler is already present, and the placement of the handler
 * depends on the presence of the ReactiveBridge handler (see {@link NettyPipeline}).
 *
 * @param context the context from which to obtain the channel and pipeline
 */
@Override
public final void preparePipeline(NettyContext context) {
	this.addHandler = context.channel()
	                         .pipeline()
	                         .get(NettyPipeline.ChunkedWriter) == null;
	if (addHandler) {
		boolean hasReactiveBridge = context.channel()
		                                   .pipeline()
		                                   .get(NettyPipeline.ReactiveBridge) != null;

		if (hasReactiveBridge) {
			context.channel()
			       .pipeline()
			       .addBefore(NettyPipeline.ReactiveBridge,
					       NettyPipeline.ChunkedWriter,
					       new ChunkedWriteHandler());
		}
		else {
			context.channel()
			       .pipeline()
			       .addLast(NettyPipeline.ChunkedWriter, new ChunkedWriteHandler());
		}
	}
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:35，代码来源:AbstractFileChunkedStrategy.java

示例7: testIssue186

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Test
public void testIssue186() {
	NettyContext server =
			HttpServer.create(0)
			          .newHandler((req, res) -> res.status(200).send())
			          .block(Duration.ofSeconds(300));

	HttpClient client =
			HttpClient.create(ops -> ops.connectAddress(() -> server.address())
					                    .poolResources(PoolResources.fixed("test", 1)));

	try {
		doTestIssue186(client);
		doTestIssue186(client);
	}
	finally {
		server.dispose();
	}

}

开发者ID:reactor，项目名称:reactor-netty，代码行数:21，代码来源:HttpServerTests.java

示例8: doHandler

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
/**
 * Create a {@link ContextHandler} for {@link Bootstrap#handler()}
 *
 * @param handler user provided in/out handler
 * @param sink user provided bind handler
 * @param secure if operation should be secured
 * @param pool if channel pool
 * @param onSetup if operation has local setup callback
 *
 * @return a new {@link ContextHandler}
 */
protected ContextHandler<SocketChannel> doHandler(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>> handler,
		MonoSink<NettyContext> sink,
		boolean secure,
		SocketAddress providedAddress,
		ChannelPool pool,
		Consumer<? super Channel> onSetup) {
	return ContextHandler.newClientContext(sink,
			options,
			loggingHandler,
			secure,
			providedAddress,
			pool,
			handler == null ? EMPTY :
					(ch, c, msg) -> ChannelOperations.bind(ch, handler, c));
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:27，代码来源:TcpClient.java

示例9: doHandler

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Override
protected ContextHandler<SocketChannel> doHandler(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>> handler,
		MonoSink<NettyContext> sink,
		boolean secure,
		SocketAddress providedAddress,
		ChannelPool pool,
		Consumer<? super Channel> onSetup) {
	return ContextHandler.<SocketChannel>newClientContext(sink,
			options,
			loggingHandler,
			secure,
			providedAddress,
			pool,
			handler != null ? (ch, c, msg) -> {
				if(onSetup != null){
					onSetup.accept(ch);
				}
				return HttpClientOperations.bindHttp(ch, handler, c);
			} : EMPTY).onPipeline(this);
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:21，代码来源:HttpClient.java

示例10: sendWebsocket

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Override
public WebsocketOutbound sendWebsocket(String subprotocols) {
	Mono<Void> m = withWebsocketSupport(websocketUri(), subprotocols, noopHandler());

	return new WebsocketOutbound() {

		@Override
		public String selectedSubprotocol() {
			return null;
		}

		@Override
		public NettyContext context() {
			return HttpClientOperations.this;
		}

		@Override
		public Mono<Void> then() {
			return m;
		}
	};
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:23，代码来源:HttpClientOperations.java

示例11: nonContentStatusCodes

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Test
public void nonContentStatusCodes() {
	NettyContext server =
			HttpServer.create(ops -> ops.host("localhost"))
			          .newRouter(r -> r.get("/204-1", (req, res) -> res.status(HttpResponseStatus.NO_CONTENT)
			                                                           .sendHeaders())
			                           .get("/204-2", (req, res) -> res.status(HttpResponseStatus.NO_CONTENT))
			                           .get("/205-1", (req, res) -> res.status(HttpResponseStatus.RESET_CONTENT)
			                                                           .sendHeaders())
			                           .get("/205-2", (req, res) -> res.status(HttpResponseStatus.RESET_CONTENT))
			                           .get("/304-1", (req, res) -> res.status(HttpResponseStatus.NOT_MODIFIED)
			                                                           .sendHeaders())
			                           .get("/304-2", (req, res) -> res.status(HttpResponseStatus.NOT_MODIFIED)))
			          .block(Duration.ofSeconds(30));

	checkResponse("/204-1", server.address());
	checkResponse("/204-2", server.address());
	checkResponse("/205-1", server.address());
	checkResponse("/205-2", server.address());
	checkResponse("/304-1", server.address());
	checkResponse("/304-2", server.address());

	server.dispose();
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:25，代码来源:HttpServerTests.java

示例12: autoAddHttpExtractor

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
static void autoAddHttpExtractor(NettyContext c, String name, ChannelHandler
		handler){

	if (handler instanceof ByteToMessageDecoder
			|| handler instanceof ByteToMessageCodec
			|| handler instanceof CombinedChannelDuplexHandler) {
		String extractorName = name+"$extractor";

		if(c.channel().pipeline().context(extractorName) != null){
			return;
		}

		c.channel().pipeline().addBefore(name, extractorName, HTTP_EXTRACTOR);

		if(NettyContext.isPersistent(c.channel())){
			c.onClose(() -> c.removeHandler(extractorName));
		}

	}
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:21，代码来源:HttpOperations.java

示例13: testTcpClient

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Test
public void testTcpClient() throws InterruptedException {
	final CountDownLatch latch = new CountDownLatch(1);

	NettyContext client = TcpClient.create("localhost", echoServerPort)
	                               .newHandler((in, out) -> {
		                               in.receive()
		                                 .log("conn")
		                                 .subscribe(s -> latch.countDown());

		                               return out.sendString(Flux.just("Hello World!"))
		                                  .neverComplete();
	                               })
	                               .block(Duration.ofSeconds(30));

	latch.await(30, TimeUnit.SECONDS);

	client.dispose();

	assertThat("latch was counted down", latch.getCount(), is(0L));
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:22，代码来源:TcpClientTests.java

示例14: testTcpClientWithInetSocketAddress

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Test
public void testTcpClientWithInetSocketAddress() throws InterruptedException {
	final CountDownLatch latch = new CountDownLatch(1);

	TcpClient client =
			TcpClient.create(echoServerPort);

	NettyContext s = client.newHandler((in, out) -> {
		in.receive()
		  .subscribe(d -> latch.countDown());

		return out.sendString(Flux.just("Hello"))
		   .neverComplete();
	})
	                       .block(Duration.ofSeconds(5));

	latch.await(5, TimeUnit.SECONDS);

	s.dispose();

	assertThat("latch was counted down", latch.getCount(), is(0L));
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:23，代码来源:TcpClientTests.java

示例15: readIdleDoesNotFireWhileDataIsBeingRead

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Test
public void readIdleDoesNotFireWhileDataIsBeingRead()
		throws InterruptedException, IOException {
	final CountDownLatch latch = new CountDownLatch(1);
	long start = System.currentTimeMillis();

	TcpClient client = TcpClient.create("localhost", heartbeatServerPort);

	NettyContext s = client.newHandler((in, out) -> {
		in.onReadIdle(500, latch::countDown);
		return Flux.never();
	})
	                       .block(Duration.ofSeconds(30));

	assertTrue(latch.await(15, TimeUnit.SECONDS));
	heartbeatServer.close();

	long duration = System.currentTimeMillis() - start;

	assertThat(duration, is(greaterThanOrEqualTo(500L)));
	s.dispose();
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:23，代码来源:TcpClientTests.java

示例16: flushOnComplete

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Test
public void flushOnComplete() {

	Flux<String> test = Flux.range(0, 100)
	                        .map(n -> String.format("%010d", n));

	NettyContext c = HttpServer.create(0)
	                           .newHandler((req, resp) -> resp.sendString(test.map(s -> s + "\n")))
	                           .block(Duration.ofSeconds(30));

	Flux<String> client = HttpClient.create(c.address()
	                                         .getPort())
	                                .get("/")
	                                .block(Duration.ofSeconds(30))
	                                .addHandler(new LineBasedFrameDecoder(10))
	                                .receive()
	                                .asString();

	StepVerifier.create(client)
	            .expectNextSequence(test.toIterable())
	            .expectComplete()
	            .verify(Duration.ofSeconds(30));

	c.dispose();
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:26，代码来源:HttpServerTests.java

示例17: prematureCancel

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Test
	public void prematureCancel() throws Exception {
		DirectProcessor<Void> signal = DirectProcessor.create();
		NettyContext x = TcpServer.create("localhost", 0)
		                          .newHandler((in, out) -> {
										signal.onComplete();
										return out.context(c -> c.addHandlerFirst(
												new HttpResponseEncoder()))
										          .sendObject(Mono.delay(Duration
												          .ofSeconds(2))
												          .map(t ->
												          new DefaultFullHttpResponse(
														          HttpVersion.HTTP_1_1,
														          HttpResponseStatus
																          .PROCESSING)))
												.neverComplete();
		                          })
		                          .block(Duration.ofSeconds(30));

		StepVerifier.create(createHttpClientForContext(x)
		                              .get("/")
		                              .timeout(signal)
		)
		            .verifyError(TimeoutException.class);
//		Thread.sleep(1000000);
	}

开发者ID:reactor，项目名称:reactor-netty，代码行数:27，代码来源:HttpClientTest.java

示例18: doTestGzip

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
private void doTestGzip(boolean gzipEnabled) {
	String expectedResponse = gzipEnabled ? "gzip" : "no gzip";
	NettyContext server = HttpServer.create(0)
	        .newHandler((req,res) -> res.sendString(
	                Mono.just(req.requestHeaders().get(HttpHeaderNames.ACCEPT_ENCODING, "no gzip"))))
	        .block(Duration.ofSeconds(30));
	StepVerifier.create(
	        HttpClient.create(ops -> ops.port(server.address().getPort()).compression(gzipEnabled))
	                  .get("/")
	                  .flatMap(r -> r.receive()
	                                 .asString()
	                                 .elementAt(0)
	                                 .zipWith(Mono.just(r)))
	        )
	            .expectNextMatches(tuple -> {
	                tuple.getT2().dispose();
	                return expectedResponse.equals(tuple.getT1());
	            })
	            .expectComplete()
	            .verify(Duration.ofSeconds(30));

	server.dispose();
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:24，代码来源:HttpClientTest.java

示例19: sshExchangeAbsoluteGet

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
@Test
public void sshExchangeAbsoluteGet() throws CertificateException, SSLException {
	SelfSignedCertificate ssc = new SelfSignedCertificate();
	SslContext sslServer = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
	SslContext sslClient = SslContextBuilder.forClient()
	                                        .trustManager(ssc.cert()).build();

	NettyContext context =
			HttpServer.create(opt -> opt.sslContext(sslServer))
			          .newHandler((req, resp) -> resp.sendString(Flux.just("hello ", req.uri())))
			          .block();

	HttpClientResponse response = HttpClient.create(
			opt -> applyHostAndPortFromContext(opt, context)
					.sslContext(sslClient))
			.get("/foo").block();
	context.dispose();
	context.onClose().block();

	String responseString = response.receive().aggregate().asString(CharsetUtil.UTF_8).block();
	assertThat(responseString).isEqualTo("hello /foo");
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:23，代码来源:HttpClientTest.java

示例20: assertSendFile

import reactor.ipc.netty.NettyContext; //导入依赖的package包/类
private void assertSendFile(Function<HttpServerResponse, NettyOutbound> fn) {
	NettyContext context =
			HttpServer.create(opt -> opt.host("localhost"))
			          .newHandler((req, resp) -> fn.apply(resp))
			          .block();


	HttpClientResponse response =
			HttpClient.create(opt -> opt.connectAddress(() -> context.address()))
			          .get("/foo")
			          .block(Duration.ofSeconds(120));

	context.dispose();
	context.onClose().block();

	String body = response.receive().aggregate().asString(StandardCharsets.UTF_8).block();

	assertThat(body)
			.startsWith("This is an UTF-8 file that is larger than 1024 bytes. " + "It contains accents like é.")
			.contains("1024 mark here -><- 1024 mark here")
			.endsWith("End of File");
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:23，代码来源:HttpServerTests.java

注：本文中的reactor.ipc.netty.NettyContext类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java BasqueAnalyzer类代码示例发布时间：2022-05-23

Java Position类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18831|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9877|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8285|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8641|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8572|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9576|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8568|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7959|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8572|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7497|2022-11-06

客服电话

电子邮件

Java NettyContext类代码示例

示例1: newHandler

示例2: newHandler

示例3: newClientContext

示例4: ContextHandler

示例5: release

示例6: preparePipeline

示例7: testIssue186

示例8: doHandler

示例9: doHandler

示例10: sendWebsocket

示例11: nonContentStatusCodes

示例12: autoAddHttpExtractor

示例13: testTcpClient

示例14: testTcpClientWithInetSocketAddress

示例15: readIdleDoesNotFireWhileDataIsBeingRead

示例16: flushOnComplete

示例17: prematureCancel

示例18: doTestGzip

示例19: sshExchangeAbsoluteGet

示例20: assertSendFile

请发表评论

全部评论

上一篇：

下一篇：

CVE-2022-34245

github/paste-markdown: Paste spreadsheet

jupyterlab/jupyterlab-latex: JupyterLab

win7系统快速打开本地连接查看网络状态的操

Altir-Team/genai-localization: Translati

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053