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

SocketChannel.write介绍

暂无

代码示例

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

@Override
protected void write(Object data, final Deferred<Void, Promise<Void>> onComplete, final boolean flush) {
  ChannelFuture writeFuture = (flush ? channel.writeAndFlush(data) : channel.write(data));
  writeFuture.addListener(new ChannelFutureListener() {
    @Override
    public void operationComplete(ChannelFuture future) throws Exception {
      boolean success = future.isSuccess();
      if(!success) {
        Throwable t = future.cause();
        eventsReactor.notify(t, Event.wrap(t));
        if(null != onComplete) {
          onComplete.accept(t);
        }
      } else if(null != onComplete) {
        onComplete.accept((Void)null);
      }
    }
  });
}

代码示例来源：origin: spullara/redis-protocol

public Promise<Reply> send(Command command) {
  Promise<Reply> reply = new Promise<>();
  synchronized (this) {
   queue.add(reply);
   socketChannel.write(command);
  }
  return reply;
 }
}

代码示例来源：origin: io.netty/netty-testsuite

ChannelFuture writeFuture = ch.write(Unpooled.wrappedBuffer(expectedBytes));
h.assertWritability(false);
ch.flush();