Function read_until_closed

src/react/observable.py:250–267

Reads and returns all available data in observable until it's closed :param observable: data to be read from :param timeout: (in sec, float) if timeout is set (non None and > 0) and wait takes more time, then TimeoutError is raised :return: all data (list), which will be read

(observable, timeout=None)

def read_until_closed(observable, timeout=None):
    """
    Reads and returns all available data in observable until it's closed
    :param observable: data to be read from
    :param timeout: (in sec, float) if timeout is set (non None and > 0) and wait takes more time, 
    then TimeoutError is raised
    :return: all data (list), which will be read 
    """
    observer = _StoringObserver()

    observable.subscribe(observer)
    observable.wait_close(timeout)

    if (timeout is not None) and (not observable.closed):
        observable.unsubscribe(observer)
        raise TimeoutError('Observable was not closed within timeout period of ' + str(timeout) + ' sec')

    return observer.data


class _CloseSubscriber: