public class BufferedIoOutputStream extends AbstractInnerCloseable implements IoOutputStream
IoOutputStream
capable of queuing write requests.AbstractCloseable.State
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<IoWriteFutureImpl> |
currentWrite |
protected Object |
id |
protected IoOutputStream |
out |
protected Queue<IoWriteFutureImpl> |
writes |
closeFuture, futureLock, state
log
Constructor and Description |
---|
BufferedIoOutputStream(Object id,
IoOutputStream out) |
Modifier and Type | Method and Description |
---|---|
protected void |
finishWrite(IoWriteFutureImpl future) |
Object |
getId() |
protected Closeable |
getInnerCloseable() |
protected void |
startWriting() |
String |
toString() |
IoWriteFuture |
writeBuffer(Buffer buffer)
Write the given buffer.
|
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, preClose, removeCloseFutureListener
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
protected final IoOutputStream out
protected final Queue<IoWriteFutureImpl> writes
protected final AtomicReference<IoWriteFutureImpl> currentWrite
protected final Object id
public BufferedIoOutputStream(Object id, IoOutputStream out)
public Object getId()
public IoWriteFuture writeBuffer(Buffer buffer) throws IOException
IoOutputStream
writeBuffer
in interface IoOutputStream
buffer
- the data to write. NOTE: the buffer must not be touched until the returned write
future is completed.IoWriteFuture
that can be used to check when the data has actually been written.IOException
- if an error occurred when writing the dataprotected void startWriting() throws IOException
IOException
protected void finishWrite(IoWriteFutureImpl future)
protected Closeable getInnerCloseable()
getInnerCloseable
in class AbstractInnerCloseable
Copyright © 2008–2022 The Apache Software Foundation. All rights reserved.