本文整理了Java中io.vertx.core.http.HttpServer.requestStream()方法的一些代码示例，展示了HttpServer.requestStream()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HttpServer.requestStream()方法的具体详情如下：
包路径：io.vertx.core.http.HttpServer
类名称：HttpServer
方法名：requestStream

HttpServer.requestStream介绍

[英]Return the request stream for the server. As HTTP requests are received by the server, instances of HttpServerRequest will be created and passed to the stream io.vertx.core.streams.ReadStream#handler(io.vertx.core.Handler).
[中]返回服务器的请求流。当服务器接收HTTP请求时，将创建HttpServerRequest的实例并将其传递给流io。维特斯。果心溪流。ReadStream处理程序（io.vertx.core.handler）。

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testClosingServerClosesRequestStreamEndHandler() {
 this.server = vertx.createHttpServer(new HttpServerOptions().setPort(HttpTestBase.DEFAULT_HTTP_PORT));
 ReadStream<HttpServerRequest> stream = server.requestStream();
 AtomicBoolean closed = new AtomicBoolean();
 stream.endHandler(v -> closed.set(true));
 stream.handler(req -> {});
 server.listen(ar -> {
  assertTrue(ar.succeeded());
  assertFalse(closed.get());
  server.close(v -> {
   assertTrue(ar.succeeded());
   assertTrue(closed.get());
   testComplete();
  });
 });
 await();
}

代码示例来源：origin: eclipse-vertx/vert.x

this.server = vertx.createHttpServer(new HttpServerOptions().setPort(HttpTestBase.DEFAULT_HTTP_PORT));
AtomicInteger done = new AtomicInteger();
ReadStream<HttpServerRequest> stream = server.requestStream();
stream.handler(req -> {});
ThreadLocal<Object> stack = new ThreadLocal<>();

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testMultipleServerClose() {
 this.server = vertx.createHttpServer(new HttpServerOptions().setPort(DEFAULT_HTTP_PORT));
 AtomicInteger times = new AtomicInteger();
 // We assume the endHandler and the close completion handler are invoked in the same context task
 ThreadLocal stack = new ThreadLocal();
 stack.set(true);
 server.requestStream().endHandler(v -> {
  assertNull(stack.get());
  assertTrue(Vertx.currentContext().isEventLoopContext());
  times.incrementAndGet();
 });
 server.close(ar1 -> {
  assertNull(stack.get());
  assertTrue(Vertx.currentContext().isEventLoopContext());
  server.close(ar2 -> {
   server.close(ar3 -> {
    assertEquals(1, times.get());
    testComplete();
   });
  });
 });
 await();
}

代码示例来源：origin: eclipse-vertx/vert.x

String path = "/some/path";
this.server = vertx.createHttpServer(new HttpServerOptions().setAcceptBacklog(10).setPort(HttpTestBase.DEFAULT_HTTP_PORT));
ReadStream<HttpServerRequest> httpStream = server.requestStream();
AtomicBoolean paused = new AtomicBoolean();
httpStream.handler(req -> {

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testClosingServerClosesRequestStreamEndHandler() {
 this.server = vertx.createHttpServer(new HttpServerOptions().setPort(HttpTestBase.DEFAULT_HTTP_PORT));
 ReadStream<HttpServerRequest> stream = server.requestStream();
 AtomicBoolean closed = new AtomicBoolean();
 stream.endHandler(v -> closed.set(true));
 stream.handler(req -> {});
 server.listen(ar -> {
  assertTrue(ar.succeeded());
  assertFalse(closed.get());
  server.close(v -> {
   assertTrue(ar.succeeded());
   assertTrue(closed.get());
   testComplete();
  });
 });
 await();
}

代码示例来源：origin: io.vertx/vertx-core

this.server = vertx.createHttpServer(new HttpServerOptions().setPort(HttpTestBase.DEFAULT_HTTP_PORT));
AtomicInteger done = new AtomicInteger();
ReadStream<HttpServerRequest> stream = server.requestStream();
stream.handler(req -> {});
ThreadLocal<Object> stack = new ThreadLocal<>();

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testMultipleServerClose() {
 this.server = vertx.createHttpServer(new HttpServerOptions().setPort(DEFAULT_HTTP_PORT));
 AtomicInteger times = new AtomicInteger();
 // We assume the endHandler and the close completion handler are invoked in the same context task
 ThreadLocal stack = new ThreadLocal();
 stack.set(true);
 server.requestStream().endHandler(v -> {
  assertNull(stack.get());
  assertTrue(Vertx.currentContext().isEventLoopContext());
  times.incrementAndGet();
 });
 server.close(ar1 -> {
  assertNull(stack.get());
  assertTrue(Vertx.currentContext().isEventLoopContext());
  server.close(ar2 -> {
   server.close(ar3 -> {
    assertEquals(1, times.get());
    testComplete();
   });
  });
 });
 await();
}

代码示例来源：origin: io.vertx/vertx-core

String path = "/some/path";
this.server = vertx.createHttpServer(new HttpServerOptions().setAcceptBacklog(10).setPort(HttpTestBase.DEFAULT_HTTP_PORT));
ReadStream<HttpServerRequest> httpStream = server.requestStream();
AtomicBoolean paused = new AtomicBoolean();
httpStream.handler(req -> {

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Return the request stream for the server. As HTTP requests are received by the server,
 * instances of {@link io.vertx.rxjava.core.http.HttpServerRequest} will be created and passed to the stream .
 * @return the request stream
 */
public io.vertx.rxjava.core.streams.ReadStream<io.vertx.rxjava.core.http.HttpServerRequest> requestStream() { 
 if (cached_0 != null) {
  return cached_0;
 }
 io.vertx.rxjava.core.streams.ReadStream<io.vertx.rxjava.core.http.HttpServerRequest> ret = io.vertx.rxjava.core.streams.ReadStream.newInstance(delegate.requestStream(), io.vertx.rxjava.core.http.HttpServerRequest.__TYPE_ARG);
 cached_0 = ret;
 return ret;
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Return the request stream for the server. As HTTP requests are received by the server,
 * instances of {@link io.vertx.rxjava.core.http.HttpServerRequest} will be created and passed to the stream {@link io.vertx.rxjava.core.streams.ReadStream#handler}.
 * @return the request stream
 */
public io.vertx.rxjava.core.streams.ReadStream<io.vertx.rxjava.core.http.HttpServerRequest> requestStream() { 
 if (cached_0 != null) {
  return cached_0;
 }
 io.vertx.rxjava.core.streams.ReadStream<io.vertx.rxjava.core.http.HttpServerRequest> ret = io.vertx.rxjava.core.streams.ReadStream.newInstance(delegate.requestStream(), io.vertx.rxjava.core.http.HttpServerRequest.__TYPE_ARG);
 cached_0 = ret;
 return ret;
}