Class AsyncWriteQueue
- java.lang.Object
-
- jdk.incubator.http.internal.common.AsyncWriteQueue
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class AsyncWriteQueue extends java.lang.Object implements java.io.Closeable
-
-
Constructor Summary
Constructors Constructor Description AsyncWriteQueue(java.util.function.BiConsumer<ByteBufferReference[],AsyncWriteQueue> consumeAction)
AsyncWriteQueue(java.util.function.BiConsumer<ByteBufferReference[],AsyncWriteQueue> consumeAction, boolean doFullDrain)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
boolean
flush()
retruns true if flushing was performedvoid
flushDelayed()
void
put(ByteBufferReference[] e)
void
putFirst(ByteBufferReference[] e)
void
setDelayed(ByteBufferReference[] delayedElement)
-
-
-
Constructor Detail
-
AsyncWriteQueue
public AsyncWriteQueue(java.util.function.BiConsumer<ByteBufferReference[],AsyncWriteQueue> consumeAction)
-
AsyncWriteQueue
public AsyncWriteQueue(java.util.function.BiConsumer<ByteBufferReference[],AsyncWriteQueue> consumeAction, boolean doFullDrain)
-
-
Method Detail
-
put
public void put(ByteBufferReference[] e) throws java.io.IOException
- Throws:
java.io.IOException
-
putFirst
public void putFirst(ByteBufferReference[] e) throws java.io.IOException
- Throws:
java.io.IOException
-
flush
public boolean flush() throws java.io.IOException
retruns true if flushing was performed- Returns:
- Throws:
java.io.IOException
-
flushDelayed
public void flushDelayed() throws java.io.IOException
- Throws:
java.io.IOException
-
setDelayed
public void setDelayed(ByteBufferReference[] delayedElement) throws java.io.IOException
- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.IOException
-
-