async def METHOD_NAME(
    qstream_protocol_context,
    message
):
    async with qstream_protocol_context() as protocol:
        protocol.reader.feed_data(
            QDataStreamProtocol.pack_message(json.dumps(message))
        )
        assert message == await protocol.read_message()