Class: Thrift::IOStreamTransport

Inherits:

BaseTransport

• Object
• BaseTransport
• Thrift::IOStreamTransport

Defined in:

lib/thrift/transport/io_stream_transport.rb

Instance Method Summary

• #close ⇒ Object
• #initialize(input, output) ⇒ IOStreamTransport constructor

  A new instance of IOStreamTransport.

• #open? ⇒ Boolean
• #read(sz) ⇒ Object
• #to_io ⇒ Object

  we’re assuming this is used in a IO.select for reading.

• #write(buf) ⇒ Object

Methods inherited from BaseTransport

#flush, #open, #read_all, #read_byte, #read_into_buffer, #set_context

Constructor Details

#initialize(input, output) ⇒ IOStreamTransport

Returns a new instance of IOStreamTransport.

# File 'lib/thrift/transport/io_stream_transport.rb', line 28

def initialize(input, output)
  @input = input
  @output = output
end

Instance Method Details

#close ⇒ Object

# File 'lib/thrift/transport/io_stream_transport.rb', line 36

def close; @input.close; @output.close end

#open? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/thrift/transport/io_stream_transport.rb', line 33

def open?; not @input.closed? or not @output.closed? end

#read(sz) ⇒ Object

# File 'lib/thrift/transport/io_stream_transport.rb', line 34

def read(sz); @input.read(sz) end

#to_io ⇒ Object

we’re assuming this is used in a IO.select for reading

# File 'lib/thrift/transport/io_stream_transport.rb', line 37

def to_io; @input end

#write(buf) ⇒ Object

# File 'lib/thrift/transport/io_stream_transport.rb', line 35

def write(buf); @output.write(Bytes.force_binary_encoding(buf)) end