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

HttpServer.websocketStream介绍

[英]Return the websocket stream for the server. If a websocket connect handshake is successful a new ServerWebSocket instance will be created and passed to the stream io.vertx.core.streams.ReadStream#handler(io.vertx.core.Handler).
[中]返回服务器的websocket流。如果websocket连接握手成功，将创建一个新的ServerWebSocket实例并将其传递给流io。维特斯。果心溪流。ReadStream处理程序（io.vertx.core.handler）。

代码示例

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

@Test
public void testClosingServerClosesWebSocketStreamEndHandler() {
 this.server = vertx.createHttpServer(new HttpServerOptions().setPort(DEFAULT_HTTP_PORT));
 ReadStream<ServerWebSocket> stream = server.websocketStream();
 AtomicBoolean closed = new AtomicBoolean();
 stream.endHandler(v -> closed.set(true));
 stream.handler(ws -> {
 });
 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(DEFAULT_HTTP_PORT));
AtomicInteger done = new AtomicInteger();
ReadStream<ServerWebSocket> stream = server.websocketStream();
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.websocketStream().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

this.server = vertx.createHttpServer(new HttpServerOptions().setAcceptBacklog(1).setPort(DEFAULT_HTTP_PORT));
AtomicBoolean paused = new AtomicBoolean();
ReadStream<ServerWebSocket> stream = server.websocketStream();
stream.handler(ws -> {
 assertFalse(paused.get());

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

@Test
public void testClosingServerClosesWebSocketStreamEndHandler() {
 this.server = vertx.createHttpServer(new HttpServerOptions().setPort(DEFAULT_HTTP_PORT));
 ReadStream<ServerWebSocket> stream = server.websocketStream();
 AtomicBoolean closed = new AtomicBoolean();
 stream.endHandler(v -> closed.set(true));
 stream.handler(ws -> {
 });
 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(DEFAULT_HTTP_PORT));
AtomicInteger done = new AtomicInteger();
ReadStream<ServerWebSocket> stream = server.websocketStream();
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.websocketStream().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

this.server = vertx.createHttpServer(new HttpServerOptions().setAcceptBacklog(1).setPort(DEFAULT_HTTP_PORT));
AtomicBoolean paused = new AtomicBoolean();
ReadStream<ServerWebSocket> stream = server.websocketStream();
stream.handler(ws -> {
 assertFalse(paused.get());

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

/**
 * Return the websocket stream for the server. If a websocket connect handshake is successful a
 * new {@link io.vertx.rxjava.core.http.ServerWebSocket} instance will be created and passed to the stream {@link io.vertx.rxjava.core.streams.ReadStream#handler}.
 * @return the websocket stream
 */
public io.vertx.rxjava.core.streams.ReadStream<io.vertx.rxjava.core.http.ServerWebSocket> websocketStream() { 
 if (cached_1 != null) {
  return cached_1;
 }
 io.vertx.rxjava.core.streams.ReadStream<io.vertx.rxjava.core.http.ServerWebSocket> ret = io.vertx.rxjava.core.streams.ReadStream.newInstance(delegate.websocketStream(), io.vertx.rxjava.core.http.ServerWebSocket.__TYPE_ARG);
 cached_1 = ret;
 return ret;
}

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

/**
 * Return the websocket stream for the server. If a websocket connect handshake is successful a
 * new {@link io.vertx.rxjava.core.http.ServerWebSocket} instance will be created and passed to the stream .
 * @return the websocket stream
 */
public io.vertx.rxjava.core.streams.ReadStream<io.vertx.rxjava.core.http.ServerWebSocket> websocketStream() { 
 if (cached_1 != null) {
  return cached_1;
 }
 io.vertx.rxjava.core.streams.ReadStream<io.vertx.rxjava.core.http.ServerWebSocket> ret = io.vertx.rxjava.core.streams.ReadStream.newInstance(delegate.websocketStream(), io.vertx.rxjava.core.http.ServerWebSocket.__TYPE_ARG);
 cached_1 = ret;
 return ret;
}