SnapshotEventFlowProcessor

java.lang.Object
- java.util.concurrent.SubmissionPublisher<Value>
- - com.faunadb.client.streaming.SnapshotEventFlowProcessor

All Implemented Interfaces:: AutoCloseable, Flow.Processor<Value,Value>, Flow.Publisher<Value>, Flow.Subscriber<Value>

public class SnapshotEventFlowProcessor
extends SubmissionPublisher<Value>
implements Flow.Processor<Value,Value>

Constructor Summary

Constructors
Constructor Description

SnapshotEventFlowProcessor(Expr target, Function<Expr,CompletableFuture<Value>> loadDocument)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`
`void`	`onError(Throwable throwable)`
`void`	`onNext(Value event)`
`void`	`onSubscribe(Flow.Subscription subscription)`
`void`	`subscribe(Flow.Subscriber<? super Value> subscriber)`

Methods inherited from class java.util.concurrent.SubmissionPublisher
close, closeExceptionally, consume, estimateMaximumLag, estimateMinimumDemand, getClosedException, getExecutor, getMaxBufferCapacity, getNumberOfSubscribers, getSubscribers, hasSubscribers, isClosed, isSubscribed, offer, offer, submit

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

- Constructor Detail
  - SnapshotEventFlowProcessor
```
public SnapshotEventFlowProcessor(Expr target,
                                  Function<Expr,CompletableFuture<Value>> loadDocument)
```
- Method Detail
  - subscribe
```
public void subscribe(Flow.Subscriber<? super Value> subscriber)
```
    Specified by:
    
    subscribe in interface Flow.Publisher<Value>
    
    Overrides:
    
    subscribe in class SubmissionPublisher<Value>
  - onSubscribe
```
public void onSubscribe(Flow.Subscription subscription)
```
    Specified by:
    
    onSubscribe in interface Flow.Subscriber<Value>
  - onNext
```
public void onNext(Value event)
```
    Specified by:
    
    onNext in interface Flow.Subscriber<Value>
  - onError
```
public void onError(Throwable throwable)
```
    Specified by:
    
    onError in interface Flow.Subscriber<Value>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface Flow.Subscriber<Value>