How to make concurent delya with rx.py

some_delay.py

!pip install rx

import time
import rx
from rx import operators as ops

PLEASE_WAIT_TIMEOUT = 2
SEARCH_TIMEOUT = 3

def utter_bot():
    print('Please wait')

def search():
    time.sleep(SEARCH_TIMEOUT)
    print('have results')

    return []


res = rx.timer(PLEASE_WAIT_TIMEOUT).pipe(
    ops.do_action(on_next=lambda _: utter_bot())
)
subscription = res.subscribe()

search()
subscription.dispose()