Method WriteQueue

netty/src/main/java/io/grpc/netty/WriteQueue.java:55–58

(Channel channel)

  private final AtomicBoolean scheduled = new AtomicBoolean();

  public WriteQueue(Channel channel) {
    this.channel = Preconditions.checkNotNull(channel, "channel");
    queue = new ConcurrentLinkedQueue<>();
  }

  /**
   * Schedule a flush on the channel.