async def METHOD_NAME(monitor):
    message = object()
    monitor.start(message_factory=lambda: message)
    await until(lambda: monitor.send_call_count == 1)
    assert monitor.send_message is message