Class: MessagePack::RPC::UNIXServerTransport::ServerSocket

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, server) ⇒ ServerSocket

Returns a new instance of ServerSocket.



144
145
146
147
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 144

def initialize(io, server)
	super(io)
	@server = server
end

Instance Method Details

#on_notify(method, param) ⇒ Object

MessageReceiver interface



160
161
162
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 160

def on_notify(method, param)
	@server.on_notify(method, param)
end

#on_request(msgid, method, param) ⇒ Object

MessageReceiver interface



155
156
157
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 155

def on_request(msgid, method, param)
	@server.on_request(self, msgid, method, param)
end

#on_response(msgid, error, result) ⇒ Object

MessageReceiver interface

Raises:



165
166
167
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 165

def on_response(msgid, error, result)
	raise Error.new("response message on server session")
end

#send_data(data) ⇒ Object

MessageSendable interface



150
151
152
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 150

def send_data(data)
	write data
end