Class: MessagePack::RPC::UDPClientTransport::ClientSocket

Inherits:
MessagePack::RPC::UDPTransport::BasicSocket show all
Defined in:
lib/msgpack/rpc/transport/udp.rb

Constant Summary

Constants inherited from MessagePack::RPC::UDPTransport::BasicSocket

MessagePack::RPC::UDPTransport::BasicSocket::HAVE_DNRL

Instance Attribute Summary

Attributes inherited from MessagePack::RPC::UDPTransport::BasicSocket

#io

Instance Method Summary collapse

Methods inherited from MessagePack::RPC::UDPTransport::BasicSocket

#on_readable

Methods included from MessageReceiver

#on_message

Constructor Details

#initialize(io, session) ⇒ ClientSocket

Returns a new instance of ClientSocket.



95
96
97
98
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 95

def initialize(io, session)
	super(io)
	@s = session
end

Instance Method Details

#on_notify(method, param, addr) ⇒ Object

MessageReceiver interface

Raises:



111
112
113
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 111

def on_notify(method, param, addr)
	raise Error.new("notify message on client session")
end

#on_request(msgid, method, param, addr) ⇒ Object

MessageReceiver interface

Raises:



106
107
108
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 106

def on_request(msgid, method, param, addr)
	raise Error.new("request message on client session")
end

#on_response(msgid, error, result, addr) ⇒ Object

MessageReceiver interface



116
117
118
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 116

def on_response(msgid, error, result, addr)
	@s.on_response(self, msgid, error, result)
end

#send_data(data) ⇒ Object

MessageSendable interface



101
102
103
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 101

def send_data(data)
	@io.send(data, 0)
end