Package com.fauna.client
Class FaunaStream<E>
- java.lang.Object
-
- java.util.concurrent.SubmissionPublisher<StreamEvent<E>>
-
- com.fauna.client.FaunaStream<E>
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,java.util.concurrent.Flow.Processor<java.util.List<java.nio.ByteBuffer>,StreamEvent<E>>
,java.util.concurrent.Flow.Publisher<StreamEvent<E>>
,java.util.concurrent.Flow.Subscriber<java.util.List<java.nio.ByteBuffer>>
public class FaunaStream<E> extends java.util.concurrent.SubmissionPublisher<StreamEvent<E>> implements java.util.concurrent.Flow.Processor<java.util.List<java.nio.ByteBuffer>,StreamEvent<E>>
-
-
Constructor Summary
Constructors Constructor Description FaunaStream(java.lang.Class<E> elementClass)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
void
onError(java.lang.Throwable throwable)
void
onNext(java.util.List<java.nio.ByteBuffer> buffers)
void
onSubscribe(java.util.concurrent.Flow.Subscription subscription)
void
subscribe(java.util.concurrent.Flow.Subscriber<? super StreamEvent<E>> 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
-
FaunaStream
public FaunaStream(java.lang.Class<E> elementClass)
-
-
Method Detail
-
subscribe
public void subscribe(java.util.concurrent.Flow.Subscriber<? super StreamEvent<E>> subscriber)
- Specified by:
subscribe
in interfacejava.util.concurrent.Flow.Publisher<E>
- Overrides:
subscribe
in classjava.util.concurrent.SubmissionPublisher<StreamEvent<E>>
-
onSubscribe
public void onSubscribe(java.util.concurrent.Flow.Subscription subscription)
- Specified by:
onSubscribe
in interfacejava.util.concurrent.Flow.Subscriber<E>
-
onNext
public void onNext(java.util.List<java.nio.ByteBuffer> buffers)
- Specified by:
onNext
in interfacejava.util.concurrent.Flow.Subscriber<E>
-
onError
public void onError(java.lang.Throwable throwable)
- Specified by:
onError
in interfacejava.util.concurrent.Flow.Subscriber<E>
-
onComplete
public void onComplete()
- Specified by:
onComplete
in interfacejava.util.concurrent.Flow.Subscriber<E>
-
-