class Endpoint

One endpoint of an execution transport.

Definitions

def initialize(control, body)

Initialize an endpoint from its connected IO objects.

Signature

parameter control IO

The bidirectional control stream.

parameter body IO

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