class Endpoint
One endpoint of an execution transport.
Definitions
def initialize(control, body)
Initialize an endpoint from its connected IO objects.
Signature
-
parameter
controlIO The bidirectional control stream.
-
parameter
bodyIO The bidirectional request and response body stream.
Implementation
def initialize(control, body)
@control = Channel.new(control)
@body = Channel.new(body)
end
attr :control
Signature
-
attribute
Channel The bidirectional control channel.
attr :body
Signature
-
attribute
Channel The bidirectional body channel.
def close
Close all channels.
Implementation
def close
@control.close
@body.close
end