Top Description Fields Constructors Methods
io.reactivex.internal.util

public final Class BlockingIgnoringReceiver

extends CountDownLatch
implements Consumer<Throwable>, Action
Class Inheritance
All Implemented Interfaces
io.reactivex.functions.Action, io.reactivex.functions.Consumer
Imports
java.util.concurrent.CountDownLatch, io.reactivex.functions.*
Stores an incoming Throwable (if any) and counts itself down.

Field Summary

Modifier and TypeField and Description
public Throwable
error

Constructor Summary

AccessConstructor and Description
public
BlockingIgnoringReceiver()

Method Summary

Modifier and TypeMethod and Description
public void
accept(Throwable
the value
e)

Implements io.reactivex.functions.Consumer.accept.

Consume the given value.
public void
run()

Implements io.reactivex.functions.Action.run.

Runs the action and optionally throws a checked exception.
Inherited from java.util.concurrent.CountDownLatch:
awaitawaitcountDowngetCounttoString

Field Detail

errorback to summary
public Throwable error

Constructor Detail

BlockingIgnoringReceiverback to summary
public BlockingIgnoringReceiver()

Method Detail

acceptback to summary
public void accept(Throwable e)

Implements io.reactivex.functions.Consumer.accept.

Doc from io.reactivex.functions.Consumer.accept.

Consume the given value.

Parameters
e:Throwable

the value

Annotations
@Override
runback to summary
public void run()

Implements io.reactivex.functions.Action.run.

Doc from io.reactivex.functions.Action.run.

Runs the action and optionally throws a checked exception.

Annotations
@Override