Class BlockingIgnoringReceiver

java.lang.Object
java.util.concurrent.CountDownLatch
io.reactivex.rxjava3.internal.util.BlockingIgnoringReceiver
All Implemented Interfaces:
Action, Consumer<Throwable>

public final class BlockingIgnoringReceiver extends CountDownLatch implements Consumer<Throwable>, Action
Stores an incoming Throwable (if any) and counts itself down.
  • Field Details

  • Constructor Details

    • BlockingIgnoringReceiver

      public BlockingIgnoringReceiver()
  • Method Details

    • accept

      public void accept(Throwable e)
      Description copied from interface: Consumer
      Consume the given value.
      Specified by:
      accept in interface Consumer<Throwable>
      Parameters:
      e - the value
    • run

      public void run()
      Description copied from interface: Action
      Runs the action and optionally throws a checked exception.
      Specified by:
      run in interface Action