class TCPSumac::Adapter

Public Class Methods

new(messenger) click to toggle source
# File lib/tcp_sumac/adapter.rb, line 4
def initialize(messenger)
  @messenger = messenger
end

Public Instance Methods

close() click to toggle source
# File lib/tcp_sumac/adapter.rb, line 26
def close
  begin
    @messenger.close
  rescue TCPMessenger::ClosedError
    raise Sumac::Adapter::ClosedError
  end
  nil
end
closed?() click to toggle source
# File lib/tcp_sumac/adapter.rb, line 35
def closed?
  @messenger.closed?
end
receive() click to toggle source
# File lib/tcp_sumac/adapter.rb, line 17
def receive
  begin
    message = @messenger.receive
  rescue TCPMessenger::ClosedError
    raise Sumac::Adapter::ClosedError
  end
  message
end
send(message) click to toggle source
# File lib/tcp_sumac/adapter.rb, line 8
def send(message)
  begin
    @messenger.send(message)
  rescue TCPMessenger::ClosedError
    raise Sumac::Adapter::ClosedError
  end
  nil
end