本文整理了Java中io.netty.channel.socket.SocketChannel.disconnect()
方法的一些代码示例,展示了SocketChannel.disconnect()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。SocketChannel.disconnect()
方法的具体详情如下:
包路径:io.netty.channel.socket.SocketChannel
类名称: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;
内容来源于网络,如有侵权,请联系作者删除!