code: async def recv_multipart_expect(self, data: Tuple[bytes, ...]=(b'',)) -> None:
          
          expect_all(await self.recv_multipart(), data)
docs: Waits for the next multipart message and asserts that it contains the given data.