Package com.couchbase.client.core.msg.kv

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

    • RangeScanContinueResponse

      public RangeScanContinueResponse(ResponseStatus status, reactor.core.publisher.Sinks.Many<CoreRangeScanItem> items, boolean keysOnly)

  • Method Details

    • items

      public reactor.core.publisher.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)