FlowableWithLatestFrom.FlowableWithLatestSubscriber

java.lang.Object
- io.reactivex.rxjava3.internal.operators.flowable.FlowableWithLatestFrom.FlowableWithLatestSubscriber

All Implemented Interfaces:

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

Enclosing class:

FlowableWithLatestFrom<T,U,R>
```
final class FlowableWithLatestFrom.FlowableWithLatestSubscriber
extends java.lang.Object
implements FlowableSubscriber<U>
```

Field Summary

Fields
Modifier and Type Field Description

private FlowableWithLatestFrom.WithLatestFromSubscriber<T,U,R> wlf

Constructor Summary

Constructors
Constructor Description

FlowableWithLatestSubscriber(FlowableWithLatestFrom.WithLatestFromSubscriber<T,U,R> wlf)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable t)`
`void`	`onNext(U t)`
`void`	`onSubscribe(org.reactivestreams.Subscription s)`	Implementors of this method should make sure everything that needs to be visible in `Subscriber.onNext(Object)` is established before calling `Subscription.request(long)`.

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

- Field Detail
  - wlf
```
private final FlowableWithLatestFrom.WithLatestFromSubscriber<T,U,R> wlf
```
- Constructor Detail
  - FlowableWithLatestSubscriber
```
FlowableWithLatestSubscriber(FlowableWithLatestFrom.WithLatestFromSubscriber<T,U,R> wlf)
```
- Method Detail
  - onSubscribe
```
public void onSubscribe(org.reactivestreams.Subscription s)
```
    Description copied from interface: FlowableSubscriber
    
    Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.
    
    Specified by:
    
    onSubscribe in interface FlowableSubscriber<U>
    
    Specified by:
    
    onSubscribe in interface org.reactivestreams.Subscriber<U>
  - onNext
```
public void onNext(U t)
```
    Specified by:
    
    onNext in interface org.reactivestreams.Subscriber<U>
  - onError
```
public void onError(java.lang.Throwable t)
```
    Specified by:
    
    onError in interface org.reactivestreams.Subscriber<U>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface org.reactivestreams.Subscriber<U>