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

WebSocketFrame.isClose介绍

暂无

代码示例

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

AtomicInteger count = new AtomicInteger();
ws.frameHandler(frame -> {
 if (frame.isClose()) {
  testComplete();
 } else {

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

if (frame.isClose()) {
  complete();
 } else {
client.websocket(DEFAULT_HTTP_PORT, HttpTestBase.DEFAULT_HTTP_HOST, "/", ws -> {
 ws.frameHandler(frame -> {
  if (frame.isClose()) {
   complete();
  } else {

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

/**
 * @return true if it's close frame
 */
public boolean isClose() { 
 boolean ret = delegate.isClose();
 return ret;
}

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

/**
 * @return true if it's close frame
 */
public boolean isClose() { 
 boolean ret = delegate.isClose();
 return ret;
}

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

@Test
 public void testInvalidMessageCode() {
  router.route("/ws-timeout/*").handler(SockJSHandler
   .create(vertx)
   .bridge(new BridgeOptions().addInboundPermitted(new PermittedOptions().setAddress("SockJSHandlerTest.testInvalidMessageCode")))
  );
  vertx.eventBus().consumer("SockJSHandlerTest.testInvalidMessageCode", msg -> msg.reply(new JsonObject()));
  client.websocket("/ws-timeout/websocket", ws -> {
   ws.writeFinalBinaryFrame(Buffer.buffer("durp!"));
   ws.frameHandler(frame -> {
    // we should get a normal frame with a error message
    if (!frame.isClose()) {
     JsonObject msg = new JsonObject(frame.binaryData());
     assertEquals("err", msg.getString("type"));
     assertEquals("invalid_json", msg.getString("body"));
     testComplete();
     ws.close();
    }
   });
  });
  await();
 }
}

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

AtomicInteger count = new AtomicInteger();
ws.frameHandler(frame -> {
 if (frame.isClose()) {
  testComplete();
 } else {

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

if (frame.isClose()) {
  complete();
 } else {
client.websocket(DEFAULT_HTTP_PORT, HttpTestBase.DEFAULT_HTTP_HOST, "/", ws -> {
 ws.frameHandler(frame -> {
  if (frame.isClose()) {
   complete();
  } else {

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

@Test
public void testTimeoutCloseCode() {
 router.route("/ws-timeout/*").handler(SockJSHandler
  .create(vertx)
  .bridge(new BridgeOptions().setPingTimeout(1))
 );
 client.websocket("/ws-timeout/websocket", ws -> ws.frameHandler(frame -> {
  if (frame.isClose()) {
   assertEquals(1001, frame.closeStatusCode());
   assertEquals("Session expired", frame.closeReason());
   testComplete();
  }
 }));
 await();
}

代码示例来源：origin: mewna/catnip

private void handleSocketFrame(final WebSocketFrame frame) {
  try {
    if(frame.isText()) {
      handleSocketData(new JsonObject(frame.textData()));
    }
    if(frame.isBinary()) {
      handleBinaryData(frame.binaryData());
    }
    if(frame.isClose()) {
      handleSocketCloseFrame(frame);
    }
  } catch(final Exception e) {
    catnip.logAdapter().error("Shard {}/{}: Failed to handle socket frame", id, limit, e);
  }
}

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

@Test
 public void testInvalidMessageCode() {
  router.route("/ws-timeout/*").handler(SockJSHandler
   .create(vertx)
   .bridge(new BridgeOptions().addInboundPermitted(new PermittedOptions().setAddress("SockJSHandlerTest.testInvalidMessageCode")))
  );
  vertx.eventBus().consumer("SockJSHandlerTest.testInvalidMessageCode", msg -> msg.reply(new JsonObject()));
  client.websocket("/ws-timeout/websocket", ws -> {
   ws.writeFinalBinaryFrame(Buffer.buffer("durp!"));
   ws.frameHandler(frame -> {
    // we should get a normal frame with a error message
    if (!frame.isClose()) {
     JsonObject msg = new JsonObject(frame.binaryData());
     assertEquals("err", msg.getString("type"));
     assertEquals("invalid_json", msg.getString("body"));
     testComplete();
     ws.close();
    }
   });
  });
  await();
 }
}

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

@Test
public void testTimeoutCloseCode() {
 router.route("/ws-timeout/*").handler(SockJSHandler
  .create(vertx)
  .bridge(new BridgeOptions().setPingTimeout(1))
 );
 client.websocket("/ws-timeout/websocket", ws -> ws.frameHandler(frame -> {
  if (frame.isClose()) {
   assertEquals(1001, frame.closeStatusCode());
   assertEquals("Session expired", frame.closeReason());
   testComplete();
  }
 }));
 await();
}