Class RangeScanContinueResponse

java.lang.Object
com.couchbase.client.core.msg.BaseResponse
com.couchbase.client.core.msg.kv.RangeScanContinueResponse
All Implemented Interfaces:
Response

public class RangeScanContinueResponse extends BaseResponse
  • Constructor Details

  • Method Details

    • items

      public Flux<CoreRangeScanItem> items()
    • feedItems

      public void feedItems(List<CoreRangeScanItem> items, boolean signalLastItem, boolean completeFeed)
      Method used in testing to feed items directly.
      Parameters:
      items -
      signalLastItem -
      completeFeed -
    • feedItems

      public void feedItems(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf itemsBuf, boolean signalLastItem, boolean completeFeed)
      Feeds the items from the buffer into the sink and completes it if needed.
      Parameters:
      itemsBuf - the buffer with the items to feed.
      completeFeed - if the sink needs to be completed at the end.
    • failFeed

      public void failFeed(Throwable cause)