Lines Matching refs:loop

32         self.loop = asyncio.new_event_loop()
33         self.set_event_loop(self.loop)
37         test_utils.run_briefly(self.loop)
39         self.loop.close()
45         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
46         reader, writer = self.loop.run_until_complete(open_connection_fut)
49         data = self.loop.run_until_complete(f)
52         data = self.loop.run_until_complete(f)
70         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
72             reader, writer = self.loop.run_until_complete(open_connection_fut)
77         data = self.loop.run_until_complete(f)
106         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
107         reader, writer = self.loop.run_until_complete(open_connection_fut)
111             self.loop.run_until_complete(f)
113         test_utils.run_briefly(self.loop)
128         stream = asyncio.StreamReader(loop=self.loop)
134         stream = asyncio.StreamReader(loop=self.loop)
141         stream = asyncio.StreamReader(loop=self.loop)
144         data = self.loop.run_until_complete(stream.read(0))
150         stream = asyncio.StreamReader(loop=self.loop)
151         read_task = self.loop.create_task(stream.read(30))
155         self.loop.call_soon(cb)
157         data = self.loop.run_until_complete(read_task)
163         stream = asyncio.StreamReader(loop=self.loop)
167         data = self.loop.run_until_complete(stream.read(5))
174         stream = asyncio.StreamReader(loop=self.loop)
175         read_task = self.loop.create_task(stream.read(1024))
179         self.loop.call_soon(cb)
181         data = self.loop.run_until_complete(read_task)
187         stream = asyncio.StreamReader(loop=self.loop)
188         read_task = self.loop.create_task(stream.read(-1))
194         self.loop.call_soon(cb)
196         data = self.loop.run_until_complete(read_task)
202         stream = asyncio.StreamReader(loop=self.loop)
205         data = self.loop.run_until_complete(stream.read(2))
210             ValueError, self.loop.run_until_complete, stream.read(2))
214             asyncio.StreamReader(limit=0, loop=self.loop)
217             asyncio.StreamReader(limit=-1, loop=self.loop)
220         stream = asyncio.StreamReader(limit=3, loop=self.loop)
222         data = self.loop.run_until_complete(stream.read(5))
229         stream = asyncio.StreamReader(loop=self.loop)
231         read_task = self.loop.create_task(stream.readline())
237         self.loop.call_soon(cb)
239         line = self.loop.run_until_complete(read_task)
245         # before the event loop is run.
247         stream = asyncio.StreamReader(limit=3, loop=self.loop)
252             ValueError, self.loop.run_until_complete, stream.readline())
256         stream = asyncio.StreamReader(limit=3, loop=self.loop)
262             ValueError, self.loop.run_until_complete, stream.readline())
271         stream = asyncio.StreamReader(loop=self.loop)
277         self.loop.run_until_complete(stream.readline())
282         self.loop.run_until_complete(stream.readline())
289         stream = asyncio.StreamReader(limit=7, loop=self.loop)
295         self.loop.call_soon(cb)
298             ValueError, self.loop.run_until_complete, stream.readline())
303         stream = asyncio.StreamReader(limit=7, loop=self.loop)
309         self.loop.call_soon(cb)
312             ValueError, self.loop.run_until_complete, stream.readline())
316         stream = asyncio.StreamReader(limit=7, loop=self.loop)
318         line = self.loop.run_until_complete(stream.readline())
324             self.loop.run_until_complete(stream.readline())
329             self.loop.run_until_complete(stream.readline())
335         stream = asyncio.StreamReader(loop=self.loop)
339         line = self.loop.run_until_complete(stream.readline())
345         stream = asyncio.StreamReader(loop=self.loop)
349         line = self.loop.run_until_complete(stream.readline())
353         stream = asyncio.StreamReader(loop=self.loop)
356         line = self.loop.run_until_complete(stream.readline())
360         stream = asyncio.StreamReader(loop=self.loop)
363         self.loop.run_until_complete(stream.readline())
365         data = self.loop.run_until_complete(stream.read(7))
371         stream = asyncio.StreamReader(loop=self.loop)
374         data = self.loop.run_until_complete(stream.readline())
379             ValueError, self.loop.run_until_complete, stream.readline())
383         stream = asyncio.StreamReader(loop=self.loop)
385             self.loop.run_until_complete(stream.readuntil(separator=b''))
388         stream = asyncio.StreamReader(loop=self.loop)
391         data = self.loop.run_until_complete(stream.readuntil(separator=b'AAA'))
396         data = self.loop.run_until_complete(stream.readuntil(b'AAA'))
401         data = self.loop.run_until_complete(stream.readuntil(b'AAA'))
406         stream = asyncio.StreamReader(loop=self.loop)
411         data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
418         data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
423         data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
428         data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
436         data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
441         stream = asyncio.StreamReader(loop=self.loop)
448             self.loop.run_until_complete(stream.readuntil(b'AAA'))
454         stream = asyncio.StreamReader(loop=self.loop, limit=3)
458             self.loop.run_until_complete(stream.readuntil(b'AAA'))
465             self.loop.run_until_complete(stream.readuntil(b'AAA'))
471         stream = asyncio.StreamReader(loop=self.loop)
474         data = self.loop.run_until_complete(stream.readexactly(0))
479             self.loop.run_until_complete(stream.readexactly(-1))
484         stream = asyncio.StreamReader(loop=self.loop)
487         read_task = self.loop.create_task(stream.readexactly(n))
493         self.loop.call_soon(cb)
495         data = self.loop.run_until_complete(read_task)
500         stream = asyncio.StreamReader(limit=3, loop=self.loop)
502         data = self.loop.run_until_complete(stream.readexactly(5))
508         stream = asyncio.StreamReader(loop=self.loop)
510         read_task = self.loop.create_task(stream.readexactly(n))
515         self.loop.call_soon(cb)
518             self.loop.run_until_complete(read_task)
526         stream = asyncio.StreamReader(loop=self.loop)
529         data = self.loop.run_until_complete(stream.readexactly(2))
534             ValueError, self.loop.run_until_complete, stream.readexactly(2))
537         stream = asyncio.StreamReader(loop=self.loop)
545         stream = asyncio.StreamReader(loop=self.loop)
550         t1 = self.loop.create_task(stream.readline())
551         t2 = self.loop.create_task(set_err())
553         self.loop.run_until_complete(asyncio.wait([t1, t2]))
558         stream = asyncio.StreamReader(loop=self.loop)
560         t = self.loop.create_task(stream.readline())
561         test_utils.run_briefly(self.loop)
563         test_utils.run_briefly(self.loop)
566         test_utils.run_briefly(self.loop)
573             def __init__(self, loop):
575                 self.loop = loop
586                 self.server = self.loop.run_until_complete(
592                 self.loop.create_task(self.handle_client(client_reader,
599                 self.server = self.loop.run_until_complete(
607                     self.loop.run_until_complete(self.server.wait_closed())
621         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
624         server = MyServer(self.loop)
626         msg = self.loop.run_until_complete(self.loop.create_task(client(addr)))
631         server = MyServer(self.loop)
633         msg = self.loop.run_until_complete(self.loop.create_task(client(addr)))
644             def __init__(self, loop, path):
646                 self.loop = loop
657                 self.server = self.loop.run_until_complete(
662                 self.loop.create_task(self.handle_client(client_reader,
668                 self.server = self.loop.run_until_complete(start)
673                     self.loop.run_until_complete(self.server.wait_closed())
687         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
691             server = MyServer(self.loop, path)
693             msg = self.loop.run_until_complete(
694                 self.loop.create_task(client(path)))
700             server = MyServer(self.loop, path)
702             msg = self.loop.run_until_complete(
703                 self.loop.create_task(client(path)))
714             def __init__(self, loop):
716                 self.loop = loop
734                 self.server = self.loop.run_until_complete(
742                     self.loop.run_until_complete(self.server.wait_closed())
761         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
763         server = MyServer(self.loop)
765         msg1, msg2 = self.loop.run_until_complete(client(addr))
778         # watcher to the event loop.
790         reader = asyncio.StreamReader(loop=self.loop, limit=1)
791         protocol = asyncio.StreamReaderProtocol(reader, loop=self.loop)
792         transport, _ = self.loop.run_until_complete(
793             self.loop.connect_read_pipe(lambda: protocol, pipe))
796         watcher.attach_loop(self.loop)
803             proc = self.loop.run_until_complete(create)
804             self.loop.run_until_complete(proc.wait())
809         data = self.loop.run_until_complete(reader.read(-1))
813         with self.assertRaisesRegex(RuntimeError, 'no current event loop'):
818         # retrieves the current loop if the loop parameter is not set
822         reader = self.loop.run_until_complete(test())
823         self.assertIs(reader._loop, self.loop)
827         # retrieves the current loop if the loop parameter is not set
830         asyncio.set_event_loop(self.loop)
832         self.assertIs(reader._loop, self.loop)
837         with self.assertRaisesRegex(RuntimeError, 'no current event loop'):
842         # retrieves the current loop if the loop parameter is not set
846         protocol = self.loop.run_until_complete(test())
847         self.assertIs(protocol._loop, self.loop)
851         # retrieves the current loop if the loop parameter is not set
854         asyncio.set_event_loop(self.loop)
857         self.assertIs(protocol._loop, self.loop)
869             loop = asyncio.get_running_loop()
870             stream = asyncio.streams.FlowControlMixin(loop)
872             loop.call_later(0.1, stream.resume_writing)
876         self.loop.run_until_complete(main())
883         # where it never gives up the event loop but the socket is
887         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
911         # Should not be stuck in an infinite loop.
914             self.loop.run_until_complete(client(*addr))
922         stream = asyncio.StreamReader(loop=self.loop)
926         stream = asyncio.StreamReader(loop=self.loop, limit=123)
930         stream = asyncio.StreamReader(loop=self.loop)
935         stream = asyncio.StreamReader(loop=self.loop)
940         stream = asyncio.StreamReader(loop=self.loop)
947         stream = asyncio.StreamReader(loop=self.loop)
948         stream._waiter = asyncio.Future(loop=self.loop)
953         self.loop.run_until_complete(stream._waiter)
958         stream = asyncio.StreamReader(loop=self.loop)
983             rd, wr = self.loop.run_until_complete(
988             data = self.loop.run_until_complete(f)
991             data = self.loop.run_until_complete(f)
996             self.loop.run_until_complete(wr.wait_closed())
1000             rd, wr = self.loop.run_until_complete(
1005             data = self.loop.run_until_complete(f)
1008             self.loop.run_until_complete(wr.wait_closed())
1023         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
1026             self.loop.run_until_complete(inner(httpd))
1045         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
1048             self.loop.run_until_complete(inner(httpd))
1055         self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
1058             rd, wr = self.loop.run_until_complete(
1063             self.loop.run_until_complete(f)
1066             data = self.loop.run_until_complete(f)