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

Channels.fireWriteComplete介绍

[英]Sends a "writeComplete" event to the first ChannelUpstreamHandler in the ChannelPipeline of the specified Channel.
[中]将“writeComplete”事件发送到指定通道的ChannelPipeline中的第一个ChannelUpstreamHandler。

代码示例

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

public void run() {
    fireWriteComplete(channel, amount);
  }
});

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

fireWriteComplete(channel, length);
} else {
  fireWriteCompleteLater(channel, length);

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

public void operationComplete(ChannelFuture f) {
    if (f.isSuccess()) {
      future.setSuccess();
      if (size != 0) {
        fireWriteComplete(HttpTunnelingClientSocketChannel.this, size);
      }
    } else {
      future.setFailure(f.getCause());
    }
  }
});

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

fireWriteComplete(channel, length);
} else {
  fireWriteCompleteLater(channel, length);

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

fireWriteComplete(this, 1);

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

fireWriteComplete(channel, writtenBytes);
} else {
  fireWriteCompleteLater(channel, writtenBytes);

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

fireWriteComplete(channel, writtenBytes);

代码示例来源：origin: k3po/k3po

@Override
public void run() {
  try {
    ChannelBuffer writeBuffer = channel.writeBuffer;
    int readableBytes = buffer.readableBytes();
    writeBuffer.writeBytes(buffer);
    future.setSuccess();
    fireWriteComplete(channel, readableBytes);
  }
  catch (ChannelException ex) {
    future.setFailure(ex);
  }
}

代码示例来源：origin: k3po/k3po

@Override
  public void operationComplete(ChannelFuture sourceFuture) throws Exception {
    if (sourceFuture.isSuccess()) {
      fireWriteComplete(targetFuture.getChannel(), amountWritten);
      targetFuture.setSuccess();
    }
    else {
      targetFuture.setFailure(sourceFuture.getCause());
    }
  }
});

代码示例来源：origin: k3po/k3po

fireWriteComplete(targetFuture.getChannel(), amountWritten);
targetFuture.setSuccess();

代码示例来源：origin: kaazing/gateway

fireWriteComplete(channel, writtenBytes);

代码示例来源：origin: kaazing/gateway

fireWriteComplete(channel, writtenBytes);