async def subscriber_recv(loop, subscriber):
    """Receive a message from a subscriber on the EII Message Bus.

    :param loop: asyncio loop
    :param subscriber: EII Message Bus Subscriber
    """
    recv = loop.run_in_executor(None, subscriber.recv)
    msg = await recv
    return msg