class

JoobQ::DeadlineIO

Inherits IO::Buffered < IO < Reference < Object

Constructors

new(io : IO, socket : Socket, command_timeout : Time::Span | Nil)
Source

Instance methods

unbuffered_close

Closes the wrapped IO.

TODO: Add return type restriction Nil

Source
unbuffered_flush

Flushes the wrapped IO.

TODO: Add return type restriction Nil

Source
unbuffered_read(slice : Bytes) : Int32

Reads at most slice.size bytes from the wrapped IO into slice. Returns the number of bytes read.

TODO: Add return type restriction Int32

Source
unbuffered_rewind

Rewinds the wrapped IO.

TODO: Add return type restriction Nil

Source
unbuffered_write(slice : Bytes) : Nil

Writes slice entirely into the wrapped IO.

TODO: Add return type restriction Nil

Source