BlockingIgnoringReceiver

java.lang.Object
- java.util.concurrent.CountDownLatch
- - io.reactivex.rxjava3.internal.util.BlockingIgnoringReceiver

All Implemented Interfaces:: Action, Consumer<java.lang.Throwable>

public final class BlockingIgnoringReceiver
extends java.util.concurrent.CountDownLatch
implements Consumer<java.lang.Throwable>, Action

Stores an incoming Throwable (if any) and counts itself down.

Field Summary

Fields
Modifier and Type Field Description

java.lang.Throwable error

Constructor Summary

Constructors
Constructor Description

BlockingIgnoringReceiver()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`accept(java.lang.Throwable e)`	Consume the given value.
`void`	`run()`	Runs the action and optionally throws a checked exception.

Methods inherited from class java.util.concurrent.CountDownLatch
await, await, countDown, getCount, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - error
```
public java.lang.Throwable error
```
- Constructor Detail
  - BlockingIgnoringReceiver
```
public BlockingIgnoringReceiver()
```
- Method Detail
  - accept
```
public void accept(java.lang.Throwable e)
```
    Description copied from interface: Consumer
    
    Consume the given value.
    
    Specified by:
    
    accept in interface Consumer<java.lang.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