Lines Matching refs:stream
128 stream = asyncio.StreamReader(loop=self.loop)
130 stream.feed_data(b'')
131 self.assertEqual(b'', stream._buffer)
134 stream = asyncio.StreamReader(loop=self.loop)
136 stream.feed_data(self.DATA)
137 self.assertEqual(self.DATA, stream._buffer)
141 stream = asyncio.StreamReader(loop=self.loop)
142 stream.feed_data(self.DATA)
144 data = self.loop.run_until_complete(stream.read(0))
146 self.assertEqual(self.DATA, stream._buffer)
150 stream = asyncio.StreamReader(loop=self.loop)
151 read_task = self.loop.create_task(stream.read(30))
154 stream.feed_data(self.DATA)
159 self.assertEqual(b'', stream._buffer)
163 stream = asyncio.StreamReader(loop=self.loop)
164 stream.feed_data(b'line1')
165 stream.feed_data(b'line2')
167 data = self.loop.run_until_complete(stream.read(5))
170 self.assertEqual(b'line2', stream._buffer)
174 stream = asyncio.StreamReader(loop=self.loop)
175 read_task = self.loop.create_task(stream.read(1024))
178 stream.feed_eof()
183 self.assertEqual(b'', stream._buffer)
187 stream = asyncio.StreamReader(loop=self.loop)
188 read_task = self.loop.create_task(stream.read(-1))
191 stream.feed_data(b'chunk1\n')
192 stream.feed_data(b'chunk2')
193 stream.feed_eof()
199 self.assertEqual(b'', stream._buffer)
202 stream = asyncio.StreamReader(loop=self.loop)
203 stream.feed_data(b'line\n')
205 data = self.loop.run_until_complete(stream.read(2))
208 stream.set_exception(ValueError())
210 ValueError, self.loop.run_until_complete, stream.read(2))
220 stream = asyncio.StreamReader(limit=3, loop=self.loop)
221 stream.feed_data(b'chunk')
222 data = self.loop.run_until_complete(stream.read(5))
224 self.assertEqual(b'', stream._buffer)
229 stream = asyncio.StreamReader(loop=self.loop)
230 stream.feed_data(b'chunk1 ')
231 read_task = self.loop.create_task(stream.readline())
234 stream.feed_data(b'chunk2 ')
235 stream.feed_data(b'chunk3 ')
236 stream.feed_data(b'\n chunk4')
241 self.assertEqual(b' chunk4', stream._buffer)
247 stream = asyncio.StreamReader(limit=3, loop=self.loop)
248 stream.feed_data(b'li')
249 stream.feed_data(b'ne1\nline2\n')
252 ValueError, self.loop.run_until_complete, stream.readline())
254 self.assertEqual(b'line2\n', stream._buffer)
256 stream = asyncio.StreamReader(limit=3, loop=self.loop)
257 stream.feed_data(b'li')
258 stream.feed_data(b'ne1')
259 stream.feed_data(b'li')
262 ValueError, self.loop.run_until_complete, stream.readline())
268 self.assertEqual(b'', stream._buffer)
271 stream = asyncio.StreamReader(loop=self.loop)
272 self.assertFalse(stream.at_eof())
274 stream.feed_data(b'some data\n')
275 self.assertFalse(stream.at_eof())
277 self.loop.run_until_complete(stream.readline())
278 self.assertFalse(stream.at_eof())
280 stream.feed_data(b'some data\n')
281 stream.feed_eof()
282 self.loop.run_until_complete(stream.readline())
283 self.assertTrue(stream.at_eof())
289 stream = asyncio.StreamReader(limit=7, loop=self.loop)
291 stream.feed_data(b'chunk1')
292 stream.feed_data(b'chunk2')
293 stream.feed_data(b'chunk3\n')
294 stream.feed_eof()
298 ValueError, self.loop.run_until_complete, stream.readline())
301 self.assertEqual(b'', stream._buffer)
303 stream = asyncio.StreamReader(limit=7, loop=self.loop)
305 stream.feed_data(b'chunk1')
306 stream.feed_data(b'chunk2\n')
307 stream.feed_data(b'chunk3\n')
308 stream.feed_eof()
312 ValueError, self.loop.run_until_complete, stream.readline())
313 self.assertEqual(b'chunk3\n', stream._buffer)
316 stream = asyncio.StreamReader(limit=7, loop=self.loop)
317 stream.feed_data(b'1234567\n')
318 line = self.loop.run_until_complete(stream.readline())
320 self.assertEqual(b'', stream._buffer)
322 stream.feed_data(b'12345678\n')
324 self.loop.run_until_complete(stream.readline())
325 self.assertEqual(b'', stream._buffer)
327 stream.feed_data(b'12345678')
329 self.loop.run_until_complete(stream.readline())
330 self.assertEqual(b'', stream._buffer)
335 stream = asyncio.StreamReader(loop=self.loop)
336 stream.feed_data(self.DATA[:6])
337 stream.feed_data(self.DATA[6:])
339 line = self.loop.run_until_complete(stream.readline())
342 self.assertEqual(b'line2\nline3\n', stream._buffer)
345 stream = asyncio.StreamReader(loop=self.loop)
346 stream.feed_data(b'some data')
347 stream.feed_eof()
349 line = self.loop.run_until_complete(stream.readline())
353 stream = asyncio.StreamReader(loop=self.loop)
354 stream.feed_eof()
356 line = self.loop.run_until_complete(stream.readline())
360 stream = asyncio.StreamReader(loop=self.loop)
361 stream.feed_data(self.DATA)
363 self.loop.run_until_complete(stream.readline())
365 data = self.loop.run_until_complete(stream.read(7))
368 self.assertEqual(b'ine3\n', stream._buffer)
371 stream = asyncio.StreamReader(loop=self.loop)
372 stream.feed_data(b'line\n')
374 data = self.loop.run_until_complete(stream.readline())
377 stream.set_exception(ValueError())
379 ValueError, self.loop.run_until_complete, stream.readline())
380 self.assertEqual(b'', stream._buffer)
383 stream = asyncio.StreamReader(loop=self.loop)
385 self.loop.run_until_complete(stream.readuntil(separator=b''))
388 stream = asyncio.StreamReader(loop=self.loop)
390 stream.feed_data(b'lineAAA')
391 data = self.loop.run_until_complete(stream.readuntil(separator=b'AAA'))
393 self.assertEqual(b'', stream._buffer)
395 stream.feed_data(b'lineAAA')
396 data = self.loop.run_until_complete(stream.readuntil(b'AAA'))
398 self.assertEqual(b'', stream._buffer)
400 stream.feed_data(b'lineAAAxxx')
401 data = self.loop.run_until_complete(stream.readuntil(b'AAA'))
403 self.assertEqual(b'xxx', stream._buffer)
406 stream = asyncio.StreamReader(loop=self.loop)
408 stream.feed_data(b'QWEaa')
409 stream.feed_data(b'XYaa')
410 stream.feed_data(b'a')
411 data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
413 self.assertEqual(b'', stream._buffer)
415 stream.feed_data(b'QWEaa')
416 stream.feed_data(b'XYa')
417 stream.feed_data(b'aa')
418 data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
420 self.assertEqual(b'', stream._buffer)
422 stream.feed_data(b'aaa')
423 data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
425 self.assertEqual(b'', stream._buffer)
427 stream.feed_data(b'Xaaa')
428 data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
430 self.assertEqual(b'', stream._buffer)
432 stream.feed_data(b'XXX')
433 stream.feed_data(b'a')
434 stream.feed_data(b'a')
435 stream.feed_data(b'a')
436 data = self.loop.run_until_complete(stream.readuntil(b'aaa'))
438 self.assertEqual(b'', stream._buffer)
441 stream = asyncio.StreamReader(loop=self.loop)
443 stream.feed_data(data)
444 stream.feed_eof()
448 self.loop.run_until_complete(stream.readuntil(b'AAA'))
451 self.assertEqual(b'', stream._buffer)
454 stream = asyncio.StreamReader(loop=self.loop, limit=3)
455 stream.feed_data(b'some dataAA')
458 self.loop.run_until_complete(stream.readuntil(b'AAA'))
460 self.assertEqual(b'some dataAA', stream._buffer)
462 stream.feed_data(b'A')
465 self.loop.run_until_complete(stream.readuntil(b'AAA'))
467 self.assertEqual(b'some dataAAA', stream._buffer)
471 stream = asyncio.StreamReader(loop=self.loop)
472 stream.feed_data(self.DATA)
474 data = self.loop.run_until_complete(stream.readexactly(0))
476 self.assertEqual(self.DATA, stream._buffer)
479 self.loop.run_until_complete(stream.readexactly(-1))
480 self.assertEqual(self.DATA, stream._buffer)
484 stream = asyncio.StreamReader(loop=self.loop)
487 read_task = self.loop.create_task(stream.readexactly(n))
490 stream.feed_data(self.DATA)
491 stream.feed_data(self.DATA)
492 stream.feed_data(self.DATA)
497 self.assertEqual(self.DATA, stream._buffer)
500 stream = asyncio.StreamReader(limit=3, loop=self.loop)
501 stream.feed_data(b'chunk')
502 data = self.loop.run_until_complete(stream.readexactly(5))
504 self.assertEqual(b'', stream._buffer)
508 stream = asyncio.StreamReader(loop=self.loop)
510 read_task = self.loop.create_task(stream.readexactly(n))
513 stream.feed_data(self.DATA)
514 stream.feed_eof()
523 self.assertEqual(b'', stream._buffer)
526 stream = asyncio.StreamReader(loop=self.loop)
527 stream.feed_data(b'line\n')
529 data = self.loop.run_until_complete(stream.readexactly(2))
532 stream.set_exception(ValueError())
534 ValueError, self.loop.run_until_complete, stream.readexactly(2))
537 stream = asyncio.StreamReader(loop=self.loop)
538 self.assertIsNone(stream.exception())
541 stream.set_exception(exc)
542 self.assertIs(stream.exception(), exc)
545 stream = asyncio.StreamReader(loop=self.loop)
548 stream.set_exception(ValueError())
550 t1 = self.loop.create_task(stream.readline())
558 stream = asyncio.StreamReader(loop=self.loop)
560 t = self.loop.create_task(stream.readline())
565 stream.set_exception(RuntimeError('message'))
567 self.assertIs(stream._waiter, None)
863 async def drainer(stream):
865 await stream._drain_helper()
870 stream = asyncio.streams.FlowControlMixin(loop)
871 stream.pause_writing()
872 loop.call_later(0.1, stream.resume_writing)
873 await asyncio.gather(*[drainer(stream) for _ in range(10)])
922 stream = asyncio.StreamReader(loop=self.loop)
923 self.assertEqual("<StreamReader>", repr(stream))
926 stream = asyncio.StreamReader(loop=self.loop, limit=123)
927 self.assertEqual("<StreamReader limit=123>", repr(stream))
930 stream = asyncio.StreamReader(loop=self.loop)
931 stream.feed_eof()
932 self.assertEqual("<StreamReader eof>", repr(stream))
935 stream = asyncio.StreamReader(loop=self.loop)
936 stream.feed_data(b'data')
937 self.assertEqual("<StreamReader 4 bytes>", repr(stream))
940 stream = asyncio.StreamReader(loop=self.loop)
942 stream.set_exception(exc)
944 repr(stream))
947 stream = asyncio.StreamReader(loop=self.loop)
948 stream._waiter = asyncio.Future(loop=self.loop)
950 repr(stream),
952 stream._waiter.set_result(None)
953 self.loop.run_until_complete(stream._waiter)
954 stream._waiter = None
955 self.assertEqual("<StreamReader>", repr(stream))
958 stream = asyncio.StreamReader(loop=self.loop)
959 stream._transport = mock.Mock()
960 stream._transport.__repr__ = mock.Mock()
961 stream._transport.__repr__.return_value = "<Transport>"
962 self.assertEqual("<StreamReader transport=<Transport>>", repr(stream))