Package com.faunadb.client.streaming
Class BodyValueFlowProcessor
- java.lang.Object
-
- java.util.concurrent.SubmissionPublisher<Value>
-
- com.faunadb.client.streaming.BodyValueFlowProcessor
-
- All Implemented Interfaces:
AutoCloseable
,Flow.Processor<List<ByteBuffer>,Value>
,Flow.Publisher<Value>
,Flow.Subscriber<List<ByteBuffer>>
public class BodyValueFlowProcessor extends SubmissionPublisher<Value> implements Flow.Processor<List<ByteBuffer>,Value>
-
-
Constructor Summary
Constructors Constructor Description BodyValueFlowProcessor(com.fasterxml.jackson.databind.ObjectMapper json, Connection connection)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
void
onError(Throwable throwable)
void
onNext(List<ByteBuffer> items)
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
-
BodyValueFlowProcessor
public BodyValueFlowProcessor(com.fasterxml.jackson.databind.ObjectMapper json, Connection connection)
-
-
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<List<ByteBuffer>>
-
onNext
public void onNext(List<ByteBuffer> items)
- Specified by:
onNext
in interfaceFlow.Subscriber<List<ByteBuffer>>
-
onError
public void onError(Throwable throwable)
- Specified by:
onError
in interfaceFlow.Subscriber<List<ByteBuffer>>
-
onComplete
public void onComplete()
- Specified by:
onComplete
in interfaceFlow.Subscriber<List<ByteBuffer>>
-
-