7
7
8
8
9
9
class BaseSocket (object ):
10
- def __init__ (self , stream , encodings ):
10
+ def __init__ (self , stream ):
11
11
self ._stream = stream
12
- self ._packer = msgpack .Packer (encoding = encodings [ 0 ], default = lambda x : x .to_msgpack ())
13
- self ._unpacker = msgpack .Unpacker (encoding = encodings [ 1 ] )
12
+ self ._packer = msgpack .Packer (default = lambda x : x .to_msgpack ())
13
+ self ._unpacker = msgpack .Unpacker ()
14
14
15
15
def close (self ):
16
16
self ._stream .close ()
@@ -49,8 +49,8 @@ def on_notify(self, method, param):
49
49
50
50
51
51
class ClientSocket (BaseSocket ):
52
- def __init__ (self , stream , transport , encodings ):
53
- BaseSocket .__init__ (self , stream , encodings )
52
+ def __init__ (self , stream , transport ):
53
+ BaseSocket .__init__ (self , stream )
54
54
self ._transport = transport
55
55
self ._stream .set_close_callback (self .on_close )
56
56
@@ -72,10 +72,9 @@ def on_response(self, msgid, error, result):
72
72
73
73
74
74
class ClientTransport (object ):
75
- def __init__ (self , session , address , reconnect_limit , encodings = ( 'utf-8' , None ) ):
75
+ def __init__ (self , session , address , reconnect_limit ):
76
76
self ._session = session
77
77
self ._address = address
78
- self ._encodings = encodings
79
78
self ._reconnect_limit = reconnect_limit ;
80
79
81
80
self ._connecting = 0
@@ -95,7 +94,7 @@ def send_message(self, message, callback=None):
95
94
96
95
def connect (self ):
97
96
stream = IOStream (self ._address .socket (), io_loop = self ._session ._loop ._ioloop )
98
- socket = ClientSocket (stream , self , self . _encodings )
97
+ socket = ClientSocket (stream , self )
99
98
socket .connect ();
100
99
101
100
def close (self ):
@@ -135,8 +134,8 @@ def on_close(self, sock):
135
134
136
135
137
136
class ServerSocket (BaseSocket ):
138
- def __init__ (self , stream , transport , encodings ):
139
- BaseSocket .__init__ (self , stream , encodings )
137
+ def __init__ (self , stream , transport ):
138
+ BaseSocket .__init__ (self , stream )
140
139
self ._transport = transport
141
140
self ._stream .read_until_close (self .on_read , self .on_read )
142
141
@@ -151,23 +150,21 @@ def on_notify(self, method, param):
151
150
152
151
153
152
class MessagePackServer (tcpserver .TCPServer ):
154
- def __init__ (self , transport , io_loop = None , encodings = None ):
153
+ def __init__ (self , transport , io_loop = None ):
155
154
self ._transport = transport
156
- self ._encodings = encodings
157
155
tcpserver .TCPServer .__init__ (self , io_loop = io_loop )
158
156
159
157
def handle_stream (self , stream , address ):
160
- ServerSocket (stream , self ._transport , self . _encodings )
158
+ ServerSocket (stream , self ._transport )
161
159
162
160
163
161
class ServerTransport (object ):
164
- def __init__ (self , address , encodings = ( 'utf-8' , None ) ):
162
+ def __init__ (self , address ):
165
163
self ._address = address ;
166
- self ._encodings = encodings
167
164
168
165
def listen (self , server ):
169
166
self ._server = server ;
170
- self ._mp_server = MessagePackServer (self , io_loop = self ._server ._loop ._ioloop , encodings = self . _encodings )
167
+ self ._mp_server = MessagePackServer (self , io_loop = self ._server ._loop ._ioloop )
171
168
self ._mp_server .listen (self ._address .port )
172
169
173
170
def close (self ):
0 commit comments