Documentation
    Preparing search index...

    Function bufferWithSemaphore

    • Use to buffer the output based on a semaphore, while its false the operator will buffer all events from the source, and as soon as the semaphore opens by emitting a true it will emit every buffered event, and all subsequent events until the semaphore closes again.

      TODO: Lift the restiction on the semaphore that it has to be replayable

      Type Parameters

      • T

      Parameters

      • source$: Observable<T>
      • semaphore$: Observable<boolean>

        has to be replayable!

      Returns Observable<T>