public class BlaubotWebsocketConnection extends BlaubotConnectionQueueMock implements IBlaubotConnection
connected, disconnnectMonitor, inputQueue, outputQueueconnectionListeners| Constructor and Description |
|---|
BlaubotWebsocketConnection(IBlaubotDevice remoteDevice,
io.netty.channel.Channel webSocketChannel) |
| Modifier and Type | Method and Description |
|---|---|
void |
disconnect()
Disconnects the connection (if connected), nothing otherwise
|
boolean |
equals(java.lang.Object o) |
java.io.InputStream |
getInputStreamForWrittenConnectionData()
Retrieve an
InputStream to get the data written to this
IBlaubotConnection via it's write*() methods. |
int |
hashCode() |
void |
write(byte[] bytes)
Writes
b.length bytes from the specified byte array
to this output stream. |
void |
write(byte[] bytes,
int byteOffset,
int byteCount)
Writes
len bytes from the specified byte array
starting at offset off to this output stream. |
void |
write(int b)
Writes the specified byte to this output stream.
|
void |
writeMockDataToInputStream(io.netty.buffer.ByteBuf data)
Write data to the stream that can be retrieved via the
IBlaubotConnections
read*() methods. |
getOtherEndpointConnection, getRemoteDevice, isConnected, read, read, read, readFully, readFully, writeMockDataToInputStreamaddConnectionListener, notifyDisconnected, removeConnectionListenerclone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitaddConnectionListener, getRemoteDevice, isConnected, read, read, read, readFully, readFully, removeConnectionListenerpublic BlaubotWebsocketConnection(IBlaubotDevice remoteDevice, io.netty.channel.Channel webSocketChannel)
public void disconnect()
IBlaubotConnectiondisconnect in interface IBlaubotConnectiondisconnect in class BlaubotConnectionQueueMockpublic void write(int b)
throws java.io.IOException
IBlaubotConnectionwrite is that one byte is written
to the output stream. The byte to be written is the eight
low-order bits of the argument b. The 24
high-order bits of b are ignored.
Subclasses of OutputStream must provide an
implementation for this method.write in interface IBlaubotConnectionwrite in class BlaubotConnectionQueueMockb - the byte.java.io.IOException - if an I/O error occurs. In particular,
an IOException may be thrown if the
output stream has been closed.java.net.SocketTimeoutException - if the socket timed outpublic void write(byte[] bytes)
throws java.io.IOException
IBlaubotConnectionb.length bytes from the specified byte array
to this output stream. The general contract for write(b)
is that it should have exactly the same effect as the call
write(b, 0, b.length).write in interface IBlaubotConnectionwrite in class BlaubotConnectionQueueMockbytes - the data.java.io.IOException - if an I/O error occurs.java.net.SocketTimeoutException - if the socket timed outOutputStream.write(byte[], int, int)public void write(byte[] bytes,
int byteOffset,
int byteCount)
throws java.io.IOException
IBlaubotConnectionlen bytes from the specified byte array
starting at offset off to this output stream.
The general contract for write(b, off, len) is that
some of the bytes in the array b are written to the
output stream in order; element b[off] is the first
byte written and b[off+len-1] is the last byte written
by this operation.
The write method of OutputStream calls
the write method of one argument on each of the bytes to be
written out. Subclasses are encouraged to override this method and
provide a more efficient implementation.
If b is null, a
NullPointerException is thrown.
If off is negative, or len is negative, or
off+len is greater than the length of the array
b, then an IndexOutOfBoundsException is thrown.write in interface IBlaubotConnectionwrite in class BlaubotConnectionQueueMockbytes - the data.byteOffset - the start offset in the data.byteCount - the number of bytes to write.java.io.IOException - if an I/O error occurs. In particular,
an IOException is thrown if the output
stream is closed.java.net.SocketTimeoutException - if the socket timed outpublic void writeMockDataToInputStream(io.netty.buffer.ByteBuf data)
IBlaubotConnections
read*() methods.data - the data to write to the input stream as byte arraypublic java.io.InputStream getInputStreamForWrittenConnectionData()
BlaubotConnectionQueueMockInputStream to get the data written to this
IBlaubotConnection via it's write*() methods.getInputStreamForWrittenConnectionData in class BlaubotConnectionQueueMockpublic boolean equals(java.lang.Object o)
equals in class BlaubotConnectionQueueMockpublic int hashCode()
hashCode in class BlaubotConnectionQueueMock