io.netty.channel.socket.SocketChannel.disconnect()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(1.2k)|赞(0)|评价(0)|浏览(146)

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

SocketChannel.disconnect介绍

暂无

代码示例

代码示例来源:origin: com.ibm.mqlight/mqlight-api

@Override
public void close(final Promise<Void> nwfuture) {
  final String methodName = "close";
  logger.entry(this, methodName, nwfuture);
  boolean alreadyClosed = closed.getAndSet(true);
  if (!alreadyClosed) {
    final ChannelFuture f = channel.disconnect();
    if (nwfuture != null) {
      f.addListener(new GenericFutureListener<ChannelFuture>() {
        @Override
        public void operationComplete(ChannelFuture future) throws Exception {
          nwfuture.setSuccess(null);
          decrementUseCount();
        }
      });
    } else {
      decrementUseCount();
    }
  } else if (nwfuture != null) {
    nwfuture.setSuccess(null);
  }
  logger.exit(this, methodName);
}

代码示例来源:origin: org.projectreactor/reactor-tcp

@Override
public void close() {
  super.close();
  closing = true;
  channel.disconnect().awaitUninterruptibly();
  channel.close().awaitUninterruptibly();
}

代码示例来源:origin: org.opendaylight.openflowjava/openflow-protocol-impl

ch.disconnect();
LOG.debug("Incoming connection rejected");
return;

相关文章