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

WebSocket.endHandler介绍

暂无

代码示例

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

@Test
public void testClearClientHandlersOnEnd() {
 String path = "/some/path";
 server = vertx.createHttpServer(new HttpServerOptions().setPort(DEFAULT_HTTP_PORT)).websocketHandler(WebSocketBase::close);
 server.listen(ar -> {
  assertTrue(ar.succeeded());
  client.websocketStream(DEFAULT_HTTP_PORT, HttpTestBase.DEFAULT_HTTP_HOST, path, null).
    handler(ws -> {
     ws.endHandler(v -> {
      try {
       ws.endHandler(null);
       ws.exceptionHandler(null);
       ws.handler(null);
      } catch (Exception e) {
       fail("Was expecting to set to null the handlers when the socket is closed");
       return;
      }
      testComplete();
     });
    });
 });
 await();
}

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

buff.appendBuffer(b);
});
ws.endHandler(v -> {

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

/**
 * This does not set up a handler on the websocket
 */
private WebSocket setupRawWebsocketClient(String serverPath)
    throws InterruptedException
{
 String requestURI = serverPath + "/websocket";
 AtomicReference<WebSocket> openedWebSocketReference = new AtomicReference<>();
 CountDownLatch openSocketCountDown = new CountDownLatch(1);
 client.websocket(requestURI, ws -> {
  openedWebSocketReference.set(ws);
  openSocketCountDown.countDown();
  ws.endHandler(v -> testComplete());
  ws.exceptionHandler(this::fail);
 });
 openSocketCountDown.await(5, TimeUnit.SECONDS);
 return openedWebSocketReference.get();
}

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

/**
 * This sets up a handler on the websocket
 */
private WebSocket setupSockJsClient(String serverPath, List<Buffer> receivedMessagesCollector)
    throws InterruptedException
{
 String requestURI = serverPath + "/000/000/websocket";
 AtomicReference<WebSocket> openedWebSocketReference = new AtomicReference<>();
 CountDownLatch openSocketCountDown = new CountDownLatch(1);
 client.websocket(requestURI, ws -> {
  openedWebSocketReference.set(ws);
  ws.handler(replyBuffer -> {
   log.debug("Client received " + replyBuffer);
   String textReply = replyBuffer.toString();
   if ("o".equals(textReply)) {
    openSocketCountDown.countDown();
   } else {
    receivedMessagesCollector.add(replyBuffer);
   }
  });
  ws.endHandler(v -> testComplete());
  ws.exceptionHandler(this::fail);
 });
 openSocketCountDown.await(5, TimeUnit.SECONDS);
 return openedWebSocketReference.get();
}

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

public io.vertx.rxjava.core.http.WebSocket endHandler(Handler<Void> endHandler) { 
 delegate.endHandler(endHandler);
 return this;
}

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

public io.vertx.rxjava.core.http.WebSocket endHandler(Handler<Void> endHandler) { 
 delegate.endHandler(endHandler);
 return this;
}

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

@Test
public void testClearClientHandlersOnEnd() {
 String path = "/some/path";
 server = vertx.createHttpServer(new HttpServerOptions().setPort(DEFAULT_HTTP_PORT)).websocketHandler(WebSocketBase::close);
 server.listen(ar -> {
  assertTrue(ar.succeeded());
  client.websocketStream(DEFAULT_HTTP_PORT, HttpTestBase.DEFAULT_HTTP_HOST, path, null).
    handler(ws -> {
     ws.endHandler(v -> {
      try {
       ws.endHandler(null);
       ws.exceptionHandler(null);
       ws.handler(null);
      } catch (Exception e) {
       fail("Was expecting to set to null the handlers when the socket is closed");
       return;
      }
      testComplete();
     });
    });
 });
 await();
}

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

buff.appendBuffer(b);
});
ws.endHandler(v -> {

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

/**
 * This does not set up a handler on the websocket
 */
private WebSocket setupRawWebsocketClient(String serverPath)
    throws InterruptedException
{
 String requestURI = serverPath + "/websocket";
 AtomicReference<WebSocket> openedWebSocketReference = new AtomicReference<>();
 CountDownLatch openSocketCountDown = new CountDownLatch(1);
 client.websocket(requestURI, ws -> {
  openedWebSocketReference.set(ws);
  openSocketCountDown.countDown();
  ws.endHandler(v -> testComplete());
  ws.exceptionHandler(this::fail);
 });
 openSocketCountDown.await(5, TimeUnit.SECONDS);
 return openedWebSocketReference.get();
}

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

/**
 * This sets up a handler on the websocket
 */
private WebSocket setupSockJsClient(String serverPath, List<Buffer> receivedMessagesCollector)
    throws InterruptedException
{
 String requestURI = serverPath + "/000/000/websocket";
 AtomicReference<WebSocket> openedWebSocketReference = new AtomicReference<>();
 CountDownLatch openSocketCountDown = new CountDownLatch(1);
 client.websocket(requestURI, ws -> {
  openedWebSocketReference.set(ws);
  ws.handler(replyBuffer -> {
   log.debug("Client received " + replyBuffer);
   String textReply = replyBuffer.toString();
   if ("o".equals(textReply)) {
    openSocketCountDown.countDown();
   } else {
    receivedMessagesCollector.add(replyBuffer);
   }
  });
  ws.endHandler(v -> testComplete());
  ws.exceptionHandler(this::fail);
 });
 openSocketCountDown.await(5, TimeUnit.SECONDS);
 return openedWebSocketReference.get();
}