Package com.couchbase.client.core.msg.manager

Class BucketConfigStreamingResponse

java.lang.Object

com.couchbase.client.core.msg.BaseResponse

com.couchbase.client.core.msg.manager.BucketConfigStreamingResponse

All Implemented Interfaces:

Response

public class BucketConfigStreamingResponse
extends BaseResponse

Method Summary

Modifier and Type	Method	Description
String	address()
void	completeStream()
reactor.core.publisher.Flux<String>	configs()
void	failStream(Throwable e)
void	pushConfig(String config)

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

Method Details

pushConfig

@Internal
public void pushConfig(String config)

completeStream

@Internal
public void completeStream()

failStream

@Internal
public void failStream(Throwable e)

configs

public reactor.core.publisher.Flux<String> configs()

address

public String address()