ForwardingSubscriber

java.lang.Object
- com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber<T>

All Implemented Interfaces:

java.util.concurrent.Flow.Subscriber<T>

Direct Known Subclasses:

AsyncSubscriberAdapter, ForwardingBodySubscriber, SerializedForwardingSubscriber
```
public abstract class ForwardingSubscriber<T>
extends java.lang.Object
implements java.util.concurrent.Flow.Subscriber<T>
```
A Subscriber<T> that forwards to a downstream Subscriber<? super T>.

Field Summary

Fields
Modifier and Type Field Description

protected Upstream upstream

Constructor Summary

Constructors
Modifier Constructor Description

protected ForwardingSubscriber()

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`protected abstract java.util.concurrent.Flow.Subscriber<? super T>`	`delegate()`	Returns the downstream to which signals are forwarded.
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable throwable)`
`void`	`onNext(T item)`
`void`	`onSubscribe(java.util.concurrent.Flow.Subscription subscription)`
`java.lang.String`	`toString()`

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

- Field Detail
  - upstream
```
protected final Upstream upstream
```
- Constructor Detail
  - ForwardingSubscriber
```
protected ForwardingSubscriber()
```
- Method Detail
  - delegate
```
protected abstract java.util.concurrent.Flow.Subscriber<? super T> delegate()
```
    Returns the downstream to which signals are forwarded.
  - onSubscribe
```
public void onSubscribe(java.util.concurrent.Flow.Subscription subscription)
```
    Specified by:
    
    onSubscribe in interface java.util.concurrent.Flow.Subscriber<T>
  - onNext
```
public void onNext(T item)
```
    Specified by:
    
    onNext in interface java.util.concurrent.Flow.Subscriber<T>
  - onError
```
public void onError(java.lang.Throwable throwable)
```
    Specified by:
    
    onError in interface java.util.concurrent.Flow.Subscriber<T>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface java.util.concurrent.Flow.Subscriber<T>
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object