Interface PullResponseHandler

All Superinterfaces:
ResponseHandler, org.reactivestreams.Subscription
All Known Implementing Classes:
AutoPullResponseHandler, BasicPullResponseHandler

public interface PullResponseHandler extends ResponseHandler, org.reactivestreams.Subscription
  • Method Details

    • installRecordConsumer

      void installRecordConsumer(BiConsumer<Record,Throwable> recordConsumer)
      Register a record consumer for each record received. STREAMING shall not be started before this consumer is registered. A null record with no error indicates the end of streaming.
      Parameters:
      recordConsumer - register a record consumer to be notified for each record received.
    • installSummaryConsumer

      void installSummaryConsumer(BiConsumer<ResultSummary,Throwable> summaryConsumer)
      Register a summary consumer to be notified when a summary is received. STREAMING shall not be started before this consumer is registered. A null summary with no error indicates a SUCCESS message with has_more=true has arrived.
      Parameters:
      summaryConsumer - register a summary consumer