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 Summary

Constructors

Constructor	Description
RangeScanContinueResponse(ResponseStatus status, Sinks.Many<CoreRangeScanItem> items, boolean keysOnly)

Method Summary

Modifier and Type	Method	Description
void	failFeed(Throwable cause)
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.
void	feedItems(List<CoreRangeScanItem> items, boolean signalLastItem, boolean completeFeed)	Method used in testing to feed items directly.
Flux<CoreRangeScanItem>	items()

Methods inherited from class com.couchbase.client.core.msg.BaseResponse

status, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

RangeScanContinueResponse

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

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)