class LavinMQ::WebSocketIO

Included Modules

Defined in:

lavinmq/http/handler/websocket.cr

Constructors

Instance Method Summary

Class methods inherited from class IO

copy(src, dst, limit : Int) : Int64
copy(src, dst) : Int64
copy

Constructor Detail

def self.new(ws : ::HTTP::WebSocket) #

[View source]

Instance Method Detail

def read_timeout=(timeout : Number) #

TODO remove when amqp-client is updated


[View source]
def read_timeout=(timeout : Time::Span | Nil) #

[View source]
def unbuffered_close #
Description copied from module IO::Buffered

Closes the wrapped IO.

TODO Add return type restriction Nil


[View source]
def unbuffered_flush #
Description copied from module IO::Buffered

Flushes the wrapped IO.

TODO Add return type restriction Nil


[View source]
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


[View source]
def unbuffered_rewind #
Description copied from module IO::Buffered

Rewinds the wrapped IO.

TODO Add return type restriction Nil


[View source]
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


[View source]