class Bones::RPC::Synchronous::Connection

This class contains behaviour of Bones::RPC socket connections.

@since 0.0.1

Public Instance Methods

write(operations) click to toggle source
# File lib/bones/rpc/synchronous/connection.rb, line 20
def write(operations)
  with_connection do |socket|
    proxy = writer.write(operations)
    if proxy
      Timeout::timeout(timeout) do
        while not proxy.registry_empty?
          writer.reader.read(proxy)
        end
      end
    end
  end
end