Make use_list configurable in connection init

Author: artembo

Diff for: tarantool/connection.py

@@ -107,6 +107,7 @@ def __init__(self, host, port,
                  connect_now=True,
                  encoding=ENCODING_DEFAULT,
                  call_16=False,
+                 use_list=True,
                  connection_timeout=CONNECTION_TIMEOUT):
         '''
         Initialize a connection to the server.
@@ -141,6 +142,7 @@ def __init__(self, host, port,
         self.error = True
         self.encoding = encoding
         self.call_16 = call_16
+        self.use_list = use_list
         self.connection_timeout = connection_timeout
         if connect_now:
             self.connect()
@@ -277,7 +279,8 @@ def _send_request_wo_reconnect(self, request):
         while True:
             try:
                 self._socket.sendall(bytes(request))
-                response = request.response_class(self, self._read_response())
+                response = request.response_class(self, self._read_response(),
+                                                  self.use_list)
                 break
             except SchemaReloadException as e:
                 self.update_schema(e.schema_version)
@@ -462,7 +465,7 @@ def _join_v16(self, server_uuid):
         self._socket.sendall(bytes(request))
 
         while True:
-            resp = Response(self, self._read_response())
+            resp = Response(self, self._read_response(), self.use_list)
             yield resp
             if resp.code == REQUEST_TYPE_OK or resp.code >= REQUEST_TYPE_ERROR:
                 return
@@ -476,7 +479,7 @@ class JoinState:
         self._socket.sendall(bytes(request))
         state = JoinState.Handshake
         while True:
-            resp = Response(self, self._read_response())
+            resp = Response(self, self._read_response(), self.use_list)
             yield resp
             if resp.code >= REQUEST_TYPE_ERROR:
                 return
@@ -505,7 +508,7 @@ def subscribe(self, cluster_uuid, server_uuid, vclock=None):
         request = RequestSubscribe(self, cluster_uuid, server_uuid, vclock)
         self._socket.sendall(bytes(request))
         while True:
-            resp = Response(self, self._read_response())
+            resp = Response(self, self._read_response(), self.use_list)
             yield resp
             if resp.code >= REQUEST_TYPE_ERROR:
                 return

Diff for: tarantool/response.py

@@ -39,7 +39,7 @@ class Response(Sequence):
     and parses binary packet received from the server.
     '''
 
-    def __init__(self, conn, response):
+    def __init__(self, conn, response, use_list=True):
         '''
         Create an instance of `Response` using data received from the server.
 
@@ -54,7 +54,7 @@ def __init__(self, conn, response):
         # created in the __new__().
         # super(Response, self).__init__()
 
-        kwargs = dict(use_list=True)
+        kwargs = dict(use_list=use_list)
         if msgpack.version >= (1, 0, 0):
             # XXX: Explain why it is necessary.
             kwargs['strict_map_key'] = False