java.util.concurrent.Flow.Subscriber<byte[]>
public class Examples.RecordSubscriber extends java.lang.Object implements java.util.concurrent.Flow.Subscriber<byte[]>
RecordSubscriber(DataSource ds)
void
onComplete()
onError(java.lang.Throwable t)
onNext(byte[] item)
onSubscribe(java.util.concurrent.Flow.Subscription subscription)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public RecordSubscriber(DataSource ds)
public void onSubscribe(java.util.concurrent.Flow.Subscription subscription)
onSubscribe
public void onNext(byte[] item)
onNext
public void onError(java.lang.Throwable t)
onError
public void onComplete()
onComplete