Class: MessagePack::RPC::UNIXClientTransport::ClientSocket

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

Instance Method Summary collapse

Methods inherited from MessagePack::RPC::UNIXTransport::BasicSocket

#on_read, #on_readable

Methods included from MessageReceiver

#on_message

Constructor Details

#initialize(io, session) ⇒ ClientSocket

Returns a new instance of ClientSocket.



89
90
91
92
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 89

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

Instance Method Details

#on_notify(method, param) ⇒ Object

MessageReceiver interface

Raises:



105
106
107
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 105

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

#on_request(msgid, method, param) ⇒ Object

MessageReceiver interface

Raises:



100
101
102
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 100

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

#on_response(msgid, error, result) ⇒ Object

MessageReceiver interface



110
111
112
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 110

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

#send_data(data) ⇒ Object

MessageSendable interface



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

def send_data(data)
	write data
end