File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ def wait(future):
75
75
new_timeout = max (deadline - loop .time (), 0 )
76
76
else :
77
77
new_timeout = None
78
- return (yield from asyncio .wait_for (future , new_timeout , loop = loop ))
78
+ return (yield from asyncio .wait_for (future , new_timeout ))
79
79
80
80
return wait
81
81
@@ -202,7 +202,6 @@ def connect(self, timeout):
202
202
self ._streamreader , self ._streamwriter = yield from asyncio .open_connection (
203
203
self ._parent .host ,
204
204
self ._parent .port ,
205
- loop = self ._io_loop ,
206
205
ssl = ssl_context ,
207
206
)
208
207
self ._streamwriter .get_extra_info ("socket" ).setsockopt (
@@ -227,13 +226,12 @@ def connect(self, timeout):
227
226
break
228
227
# This may happen in the `V1_0` protocol where we send two requests as
229
228
# an optimization, then need to read each separately
230
- if request is not "" :
229
+ if request != "" :
231
230
self ._streamwriter .write (request )
232
231
233
232
response = yield from asyncio .wait_for (
234
233
_read_until (self ._streamreader , b"\0 " ),
235
234
timeout ,
236
- loop = self ._io_loop ,
237
235
)
238
236
response = response [:- 1 ]
239
237
except ReqlAuthError :
You can’t perform that action at this time.
0 commit comments