SnapshotEventFlowProcessor

Warning:
Fauna is decommissioning FQL v4 on June 30, 2025.

This driver is not compatible with FQL v10, the latest version. Fauna accounts created after August 21, 2024 must use FQL v10.
Ensure you migrate existing projects to the official v10 driver by the v4 EOL date: https://github.com/fauna/fauna-jvm.

For more information, see the v4 end of life (EOL) announcement and related FAQ.

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>