BlockingFlowableMostRecent.MostRecentSubscriber

java.lang.Object
- io.reactivex.rxjava3.subscribers.DefaultSubscriber<T>
- - io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableMostRecent.MostRecentSubscriber<T>

All Implemented Interfaces:

FlowableSubscriber<T>, org.reactivestreams.Subscriber<T>

Enclosing class:

BlockingFlowableMostRecent<T>
```
static final class BlockingFlowableMostRecent.MostRecentSubscriber<T>
extends DefaultSubscriber<T>
```

Nested Class Summary

Nested Classes
Modifier and Type Class Description

(package private) class BlockingFlowableMostRecent.MostRecentSubscriber.Iterator

Field Summary

Fields
Modifier and Type Field Description

(package private) java.lang.Object value

Constructor Summary

Constructors
Constructor Description

MostRecentSubscriber(T value)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`BlockingFlowableMostRecent.MostRecentSubscriber.Iterator`	`getIterable()`	The `BlockingFlowableMostRecent.MostRecentSubscriber.Iterator` return is not thread safe.
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable e)`
`void`	`onNext(T args)`

Methods inherited from class io.reactivex.rxjava3.subscribers.DefaultSubscriber
cancel, onStart, onSubscribe, request

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

- Field Detail
  - value
```
volatile java.lang.Object value
```
- Constructor Detail
  - MostRecentSubscriber
```
MostRecentSubscriber(T value)
```
- Method Detail
  - onComplete
```
public void onComplete()
```
  - onError
```
public void onError(java.lang.Throwable e)
```
  - onNext
```
public void onNext(T args)
```
  - getIterable
```
public BlockingFlowableMostRecent.MostRecentSubscriber.Iterator getIterable()
```
    The BlockingFlowableMostRecent.MostRecentSubscriber.Iterator return is not thread safe. In other words don't call BlockingFlowableMostRecent.MostRecentSubscriber.Iterator.hasNext() in one thread expect BlockingFlowableMostRecent.MostRecentSubscriber.Iterator.next() called from a different thread to work.
    
    Returns:
    
    the Iterator