Method test_create_waiter

tests/test_streams.py:25–28

(self)

        return streams.StreamReader(loop=self.loop, *args, **kwargs)

    def test_create_waiter(self):
        stream = self._make_one()
        stream._waiter = asyncio.Future(loop=self.loop)
        self.assertRaises(RuntimeError, stream._create_waiter, 'test')

    @mock.patch('aiohttp.streams.asyncio')
    def test_ctor_global_loop(self, m_asyncio):