Package com.faunadb.client.streaming
Class 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
-
-
-
-
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 interfaceFlow.Publisher<Value>
- Overrides:
subscribe
in classSubmissionPublisher<Value>
-
onSubscribe
public void onSubscribe(Flow.Subscription subscription)
- Specified by:
onSubscribe
in interfaceFlow.Subscriber<Value>
-
onNext
public void onNext(Value event)
- Specified by:
onNext
in interfaceFlow.Subscriber<Value>
-
onError
public void onError(Throwable throwable)
- Specified by:
onError
in interfaceFlow.Subscriber<Value>
-
onComplete
public void onComplete()
- Specified by:
onComplete
in interfaceFlow.Subscriber<Value>
-
-