FlowableSamplePublisher.SamplerSubscriber

java.lang.Object
- io.reactivex.rxjava3.internal.operators.flowable.FlowableSamplePublisher.SamplerSubscriber<T>

All Implemented Interfaces:

FlowableSubscriber<java.lang.Object>, org.reactivestreams.Subscriber<java.lang.Object>

Enclosing class:

FlowableSamplePublisher<T>
```
static final class FlowableSamplePublisher.SamplerSubscriber<T>
extends java.lang.Object
implements FlowableSubscriber<java.lang.Object>
```

Field Summary

Fields
Modifier and Type Field Description

(package private) FlowableSamplePublisher.SamplePublisherSubscriber<T> parent

Constructor Summary

Constructors
Constructor Description

SamplerSubscriber(FlowableSamplePublisher.SamplePublisherSubscriber<T> parent)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable t)`
`void`	`onNext(java.lang.Object 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
  - parent
```
final FlowableSamplePublisher.SamplePublisherSubscriber<T> parent
```
- Constructor Detail
  - SamplerSubscriber
```
SamplerSubscriber(FlowableSamplePublisher.SamplePublisherSubscriber<T> parent)
```
- 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<T>
    
    Specified by:
    
    onSubscribe in interface org.reactivestreams.Subscriber<T>
  - onNext
```
public void onNext(java.lang.Object t)
```
    Specified by:
    
    onNext in interface org.reactivestreams.Subscriber<T>
  - onError
```
public void onError(java.lang.Throwable t)
```
    Specified by:
    
    onError in interface org.reactivestreams.Subscriber<T>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface org.reactivestreams.Subscriber<T>