class LavinMQ::WebSocketIO
- LavinMQ::WebSocketIO
- IO
- Reference
- Object
Included Modules
Defined in:
lavinmq/http/handler/websocket.crConstructors
Instance Method Summary
-
#read_timeout=(timeout : Number)
TODO remove when amqp-client is updated
- #read_timeout=(timeout : Time::Span | Nil)
-
#unbuffered_close
Closes the wrapped
IO. -
#unbuffered_flush
Flushes the wrapped
IO. -
#unbuffered_read(slice : Bytes)
Reads at most slice.size bytes from the wrapped
IOinto slice. -
#unbuffered_rewind
Rewinds the wrapped
IO. -
#unbuffered_write(slice : Bytes) : Nil
Writes slice entirely into the wrapped
IO.
Class methods inherited from class IO
copy(src, dst, limit : Int) : Int64copy(src, dst) : Int64 copy
Constructor Detail
Instance Method Detail
def unbuffered_close
#
Description copied from module IO::Buffered
Closes the wrapped IO.
TODO Add return type restriction Nil
def unbuffered_flush
#
Description copied from module IO::Buffered
Flushes the wrapped IO.
TODO Add return type restriction Nil
def unbuffered_read(slice : Bytes)
#
Description copied from module IO::Buffered
Reads at most slice.size bytes from the wrapped IO into slice.
Returns the number of bytes read.
TODO Add return type restriction Int32
def unbuffered_rewind
#
Description copied from module IO::Buffered
Rewinds the wrapped IO.
TODO Add return type restriction Nil
def unbuffered_write(slice : Bytes) : Nil
#
Description copied from module IO::Buffered
Writes slice entirely into the wrapped IO.
TODO Add return type restriction Nil