class

Rayo::PG::BlockingTransport

Inherits Reference < Object

Raw blocking syscalls: drain writes and reads together so a large pipeline cannot deadlock when both peers fill their socket buffers.

Constructors

new(url : String, max_depth : Int32 = 16384)

conn

detach

Startup may block; the worker then transfers this authenticated socket to its ring.

drain

flush

pending

query(stmt : Statement, *args, state : Int64 = 0_i64, &callback : Result, Int64 -> Nil) : Nil

query(stmt : Statement, *args, state : Pointer(T), &callback : Result, Pointer(Void) -> Nil) : Nil forall T

receive