MessagePack::RPC::Server

    # File lib/msgpack/rpc/server.rb, line 27
27:         def initialize(arg1=nil, arg2=nil)
28:                 super(arg1, arg2)
29:                 @dispatcher = nil
30:                 @listeners = []
31:         end

    # File lib/msgpack/rpc/server.rb, line 70
70:         def close
71:                 @listeners.reject! {|listener|
72:                         listener.close
73:                         true
74:                 }
75:                 super
76:         end

    # File lib/msgpack/rpc/server.rb, line 48
48:         def listen(arg1, arg2 = nil, arg3 = nil, arg4 = nil)
49:                 if arg1.respond_to?(:listen)
50:                         # 1.
51:                         listener = arg1
52:                         obj      = arg2
53:                         accept   = arg3 || obj.public_methods
54:                 else
55:                         # 2.
56:                         listener = TCPServerTransport.new(Address.new(arg1,arg2))
57:                         obj      = arg3
58:                         accept   = arg4 || obj.public_methods
59:                 end
60: 
61:                 unless obj.nil?
62:                         serve(obj, accept)
63:                 end
64: 
65:                 listener.listen(self)
66:                 @listeners.push(listener)
67:                 nil
68:         end

    # File lib/msgpack/rpc/server.rb, line 35
35:         def serve(obj, accept = obj.public_methods)
36:                 if obj.is_a?(Dispatcher)
37:                         # 2.
38:                         @dispatcher = obj
39:                 else
40:                         # 1.
41:                         @dispatcher = ObjectDispatcher.new(obj, accept)
42:                 end
43:                 self
44:         end