Class: MessagePack::RPC::UDPClientTransport

Inherits:
Object
  • Object
show all
Defined in:
lib/msgpack/rpc/transport/udp.rb

Defined Under Namespace

Classes: ClientSocket

Instance Method Summary collapse

Constructor Details

#initialize(session, address) ⇒ UDPClientTransport

Returns a new instance of UDPClientTransport.



63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 63

def initialize(session, address)
  io = UDPSocket.new
  io.connect(*address)

  begin
    @sock = ClientSocket.new(io, session)
  rescue
    io.close
    raise
  end

  begin
    session.loop.attach(@sock)
  rescue
    @sock.close
    raise
  end
end

Instance Method Details

#close ⇒ Object

ClientTransport interface



88
89
90
91
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 88

def close
  @sock.detach if @sock.attached?
  @sock.close
end

#send_data(data) ⇒ Object

ClientTransport interface



83
84
85
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 83

def send_data(data)
  @sock.send_data(data)
end