public class ChannelOutputStream extends java.io.OutputStream implements java.nio.channels.Channel, ChannelHolder
Modifier and Type | Field and Description |
---|---|
private byte[] |
b |
private Buffer |
buffer |
private int |
bufferLength |
private AbstractChannel |
channelInstance |
private java.util.concurrent.atomic.AtomicBoolean |
closedState |
private byte |
cmd |
static long |
DEFAULT_WAIT_FOR_SPACE_TIMEOUT |
private boolean |
eofOnClose |
private int |
lastSize |
private org.slf4j.Logger |
log |
private long |
maxWaitTimeout |
private boolean |
noDelay |
private PacketWriter |
packetWriter |
private Window |
remoteWindow |
static java.lang.String |
WAIT_FOR_SPACE_TIMEOUT
Configure max.
|
Constructor and Description |
---|
ChannelOutputStream(AbstractChannel channel,
Window remoteWindow,
org.slf4j.Logger log,
byte cmd,
boolean eofOnClose) |
ChannelOutputStream(AbstractChannel channel,
Window remoteWindow,
long maxWaitTimeout,
org.slf4j.Logger log,
byte cmd,
boolean eofOnClose) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
flush() |
AbstractChannel |
getChannel() |
boolean |
isEofOnClose() |
boolean |
isNoDelay() |
boolean |
isOpen() |
protected void |
newBuffer(int size) |
void |
setNoDelay(boolean noDelay) |
java.lang.String |
toString() |
void |
write(byte[] buf,
int s,
int l) |
void |
write(int w) |
public static final java.lang.String WAIT_FOR_SPACE_TIMEOUT
public static final long DEFAULT_WAIT_FOR_SPACE_TIMEOUT
private final AbstractChannel channelInstance
private final PacketWriter packetWriter
private final Window remoteWindow
private final long maxWaitTimeout
private final org.slf4j.Logger log
private final byte cmd
private final boolean eofOnClose
private final byte[] b
private final java.util.concurrent.atomic.AtomicBoolean closedState
private Buffer buffer
private int bufferLength
private int lastSize
private boolean noDelay
public ChannelOutputStream(AbstractChannel channel, Window remoteWindow, org.slf4j.Logger log, byte cmd, boolean eofOnClose)
public ChannelOutputStream(AbstractChannel channel, Window remoteWindow, long maxWaitTimeout, org.slf4j.Logger log, byte cmd, boolean eofOnClose)
public AbstractChannel getChannel()
getChannel
in interface ChannelHolder
Channel
instancepublic boolean isEofOnClose()
public void setNoDelay(boolean noDelay)
public boolean isNoDelay()
public boolean isOpen()
isOpen
in interface java.nio.channels.Channel
public void write(int w) throws java.io.IOException
write
in class java.io.OutputStream
java.io.IOException
public void write(byte[] buf, int s, int l) throws java.io.IOException
write
in class java.io.OutputStream
java.io.IOException
public void flush() throws java.io.IOException
flush
in interface java.io.Flushable
flush
in class java.io.OutputStream
java.io.IOException
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface java.nio.channels.Channel
close
in class java.io.OutputStream
java.io.IOException
protected void newBuffer(int size)
public java.lang.String toString()
toString
in class java.lang.Object