Skip to content

Commit

Permalink
Test for stream .read() / .readany() / .iter_any() (#3525) (#3527)
Browse files Browse the repository at this point in the history
  • Loading branch information
socketpair committed Jan 21, 2019
1 parent 94e7b49 commit 0e7ea88
Showing 1 changed file with 33 additions and 0 deletions.
33 changes: 33 additions & 0 deletions tests/test_streams.py
Original file line number Diff line number Diff line change
Expand Up @@ -649,6 +649,39 @@ async def test_begin_and_end_chunk_receiving(self) -> None:
assert b'' == data
assert not end_of_chunk

async def test_readany_chunk_end_race(self) -> None:
stream = self._make_one()
stream.begin_http_chunk_receiving()
stream.feed_data(b'part1')

data = await stream.readany()
assert data == b'part1'

loop = asyncio.get_event_loop()
task = loop.create_task(stream.readany())

# Give a chance for task to create waiter and start waiting for it.
await asyncio.sleep(0.1)
assert stream._waiter is not None
assert not task.done() # Just for sure.

# This will trigger waiter, but without feeding any data.
# The stream should re-create waiter again.
stream.end_http_chunk_receiving()

# Give a chance for task to resolve.
# If everything is OK, previous action SHOULD NOT resolve the task.
await asyncio.sleep(0.1)
assert not task.done() # The actual test.

stream.begin_http_chunk_receiving()
# This SHOULD unblock the task actually.
stream.feed_data(b'part2')
stream.end_http_chunk_receiving()

data = await task
assert data == b'part2'

async def test_end_chunk_receiving_without_begin(self) -> None:
stream = self._make_one()
with pytest.raises(RuntimeError):
Expand Down

0 comments on commit 0e7ea88

Please sign in to comment.