def METHOD_NAME(self) -> None:
    # Create the table stream.
    table = data._TableStream("foo",
                              data._Relation(
                                  self.relation,
                              ),
                              subscribed=True)
    foo_factory = utils.FakeTableFactory("foo", self.relation)
    foo_faker = foo_factory.create_table(utils.table_id1)
    rb_data: List[List[Any]] = [
        [b"foo", b"bar", b"baz", b"bat"], [200, 500, 301, 404]]
    # A data rowbatch.
    batch1 = foo_faker.row_batch(rb_data)
    # The end of table row batch.
    batch2 = foo_faker.row_batch([[], []], eos=True, eow=True)
    # Push the rowbatches onto this table stream.
    table.add_row_batch(batch1)
    table.add_row_batch(batch2)
    async def process_rows() -> None:
        i = 0
        async for row in table:
            self.assertEqual(row["resp_body"], rb_data[0][i])
            self.assertEqual(row["resp_status"], rb_data[1][i])
            i += 1
    loop = asyncio.get_event_loop()
    loop.run_until_complete(process_rows())