public ChannelFuture enqueue(QueuedCommand command, boolean rst) {
        return enqueue(command);
    }
@Test
    @Disabled
    void testChunk() throws Exception {
        WriteQueue writeQueue = new WriteQueue();
        // test deque chunk size
        EmbeddedChannel embeddedChannel = new EmbeddedChannel();
        TripleStreamChannelFuture tripleStreamChannelFuture = new TripleStreamChannelFuture(embeddedChannel);
        writeMethodCalledTimes.set(0);
        for (int i = 0; i < DEQUE_CHUNK_SIZE; i++) {
            writeQueue.enqueue(HeaderQueueCommand.createHeaders(tripleStreamChannelFuture, new DefaultHttp2Headers())
                    .channel(channel));
        }
        writeQueue.enqueue(HeaderQueueCommand.createHeaders(tripleStreamChannelFuture, new DefaultHttp2Headers())
                .channel(channel));
        while (writeMethodCalledTimes.get() != (DEQUE_CHUNK_SIZE + 1)) {
            Thread.sleep(50);
        }
        Mockito.verify(channel, Mockito.times(DEQUE_CHUNK_SIZE + 1)).write(Mockito.any(), Mockito.any());
    }