WriteStreamSubscriber (aws-sdk 0.0.1-SNAPSHOT API)

java.lang.Object
- io.reactiverse.awssdk.reactivestreams.WriteStreamSubscriber<T>

All Implemented Interfaces:: Subscriber<java.nio.ByteBuffer>

Direct Known Subclasses:: HttpClientRequestSubscriber

public class WriteStreamSubscriber<T extends WriteStream<Buffer>>
extends java.lang.Object
implements Subscriber<java.nio.ByteBuffer>

Field Summary

Fields
Modifier and Type Field Description

protected static long BUFF_SIZE

protected T stream

Constructor Summary

Constructors
Constructor Description

WriteStreamSubscriber(T stream)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable t)`
`void`	`onNext(java.nio.ByteBuffer byteBuffer)`
`void`	`onSubscribe(Subscription subscription)`

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

- Field Detail
  - BUFF_SIZE
```
protected static final long BUFF_SIZE
```
    See Also:
    
    Constant Field Values
  - stream
```
protected T extends WriteStream<Buffer> stream
```
- Constructor Detail
  - WriteStreamSubscriber
```
public WriteStreamSubscriber(T stream)
```
- Method Detail
  - onSubscribe
```
public void onSubscribe(Subscription subscription)
```
    Specified by:
    
    onSubscribe in interface Subscriber<T extends WriteStream<Buffer>>
  - onNext
```
public void onNext(java.nio.ByteBuffer byteBuffer)
```
    Specified by:
    
    onNext in interface Subscriber<T extends WriteStream<Buffer>>
  - onError
```
public void onError(java.lang.Throwable t)
```
    Specified by:
    
    onError in interface Subscriber<T extends WriteStream<Buffer>>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface Subscriber<T extends WriteStream<Buffer>>