Interface RCountDownLatchRx

    • Method Detail

      • await

        io.reactivex.rxjava3.core.Completable await()
        Waits until counter reach zero.
        Returns:
        void
      • await

        io.reactivex.rxjava3.core.Single<Boolean> await​(long waitTime,
                                                        TimeUnit unit)
        Waits until counter reach zero or up to defined timeout.
        Parameters:
        waitTime - the maximum time to wait
        unit - the time unit
        Returns:
        true if the count reached zero and false if timeout reached before the count reached zero
      • countDown

        io.reactivex.rxjava3.core.Completable countDown()
        Decrements the counter of the latch. Notifies all waiting threads when count reaches zero.
        Returns:
        void
      • getCount

        io.reactivex.rxjava3.core.Single<Long> getCount()
        Returns value of current count.
        Returns:
        the current count
      • trySetCount

        io.reactivex.rxjava3.core.Single<Boolean> trySetCount​(long count)
        Sets new count value only if previous count already has reached zero or is not set at all.
        Parameters:
        count - - number of times countDown must be invoked before threads can pass through await
        Returns:
        true if new count setted false if previous count has not reached zero