class AMQP::Client::WebSocketIO

• AMQP::Client::WebSocketIO
• IO
• Reference
• Object

Included Modules

• IO::Buffered

Defined in:

amqp-client/websocket_io.cr

Constructors

• .new(ws : HTTP::WebSocket)

Instance Method Summary

• #read_timeout=(timeout)
• #unbuffered_close : Nil

  Closes the wrapped IO.

• #unbuffered_flush

  Flushes the wrapped IO.

• #unbuffered_read(bytes : Bytes)

  Reads at most slice.size bytes from the wrapped IO into slice.

• #unbuffered_rewind

  Rewinds the wrapped IO.

• #unbuffered_write(bytes : Bytes) : Nil

  Writes at most slice.size bytes from slice into the wrapped IO.

Constructor Detail

Instance Method Detail