Class MessageOutputStream
- java.lang.Object
-
- java.io.OutputStream
-
- org.eclipse.jetty.websocket.common.message.MessageOutputStream
-
- All Implemented Interfaces:
java.io.Closeable
,java.io.Flushable
,java.lang.AutoCloseable
public class MessageOutputStream extends java.io.OutputStream
Support for writing a single WebSocket BINARY message via aOutputStream
-
-
Field Summary
Fields Modifier and Type Field Description private BlockingWriteCallback
blocker
private java.nio.ByteBuffer
buffer
private org.eclipse.jetty.io.ByteBufferPool
bufferPool
private WriteCallback
callback
private boolean
closed
private BinaryFrame
frame
private long
frameCount
private static org.eclipse.jetty.util.log.Logger
LOG
private OutgoingFrames
outgoing
-
Constructor Summary
Constructors Constructor Description MessageOutputStream(OutgoingFrames outgoing, int bufferSize, org.eclipse.jetty.io.ByteBufferPool bufferPool)
MessageOutputStream(WebSocketSession session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
flush()
private void
flush(boolean fin)
private void
notifyFailure(java.lang.Throwable failure)
private void
notifySuccess()
private void
send(byte[] bytes, int offset, int length)
void
setCallback(WriteCallback callback)
void
write(byte[] bytes, int off, int len)
void
write(int b)
-
-
-
Field Detail
-
LOG
private static final org.eclipse.jetty.util.log.Logger LOG
-
outgoing
private final OutgoingFrames outgoing
-
bufferPool
private final org.eclipse.jetty.io.ByteBufferPool bufferPool
-
blocker
private final BlockingWriteCallback blocker
-
frameCount
private long frameCount
-
frame
private BinaryFrame frame
-
buffer
private java.nio.ByteBuffer buffer
-
callback
private WriteCallback callback
-
closed
private boolean closed
-
-
Constructor Detail
-
MessageOutputStream
public MessageOutputStream(WebSocketSession session)
-
MessageOutputStream
public MessageOutputStream(OutgoingFrames outgoing, int bufferSize, org.eclipse.jetty.io.ByteBufferPool bufferPool)
-
-
Method Detail
-
write
public void write(byte[] bytes, int off, int len) throws java.io.IOException
- Overrides:
write
in classjava.io.OutputStream
- Throws:
java.io.IOException
-
write
public void write(int b) throws java.io.IOException
- Specified by:
write
in classjava.io.OutputStream
- Throws:
java.io.IOException
-
flush
public void flush() throws java.io.IOException
- Specified by:
flush
in interfacejava.io.Flushable
- Overrides:
flush
in classjava.io.OutputStream
- 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
- Overrides:
close
in classjava.io.OutputStream
- Throws:
java.io.IOException
-
flush
private void flush(boolean fin) throws java.io.IOException
- Throws:
java.io.IOException
-
send
private void send(byte[] bytes, int offset, int length) throws java.io.IOException
- Throws:
java.io.IOException
-
setCallback
public void setCallback(WriteCallback callback)
-
notifySuccess
private void notifySuccess()
-
notifyFailure
private void notifyFailure(java.lang.Throwable failure)
-
-