async def METHOD_NAME(push, pull):
    sent = [b'basic']
    push.send_multipart(sent)
    f = asyncio.Future()
    def callback(msg):
        f.set_result(msg)
    pull.on_recv(callback)
    recvd = await asyncio.wait_for(f, timeout=5)
    assert recvd == sent