aboutsummaryrefslogtreecommitdiffstats
path: root/mitmproxy/master.py
diff options
context:
space:
mode:
authorAldo Cortesi <aldo@nullcube.com>2018-03-31 19:50:36 +1300
committerAldo Cortesi <aldo@corte.si>2018-04-01 09:46:32 +1200
commitb6d943cfa3a226651e705ff45aa7154010ea29ba (patch)
treebc8aabd32dba9fefcace1bb0d943f8a71f50ba54 /mitmproxy/master.py
parent54170ee6572e8ba38b94a4e51f3c8e832e5f9ac7 (diff)
downloadmitmproxy-b6d943cfa3a226651e705ff45aa7154010ea29ba.tar.gz
mitmproxy-b6d943cfa3a226651e705ff45aa7154010ea29ba.tar.bz2
mitmproxy-b6d943cfa3a226651e705ff45aa7154010ea29ba.zip
asyncio: fix client replay
Diffstat (limited to 'mitmproxy/master.py')
-rw-r--r--mitmproxy/master.py8
1 files changed, 1 insertions, 7 deletions
diff --git a/mitmproxy/master.py b/mitmproxy/master.py
index a23be0a7..c2d2b6a0 100644
--- a/mitmproxy/master.py
+++ b/mitmproxy/master.py
@@ -202,13 +202,7 @@ class Master:
host = f.request.headers.pop(":authority")
f.request.headers.insert(0, "host", host)
- rt = http_replay.RequestReplayThread(
- self.options,
- f,
- asyncio.get_event_loop(),
- self.event_queue,
- self.should_exit
- )
+ rt = http_replay.RequestReplayThread(self.options, f, self.server.channel)
rt.start() # pragma: no cover
if block:
rt.join()