Package | Description |
---|---|
com.couchbase.client.core.endpoint.query.parser | |
com.couchbase.client.core.utils |
Modifier and Type | Field and Description |
---|---|
protected UnicastAutoReleaseSubject<ByteBuf> |
YasjlQueryResponseParser.queryErrorObservable
Represents an observable that sends errors and warnings if any during query execution.
|
protected UnicastAutoReleaseSubject<ByteBuf> |
YasjlQueryResponseParser.queryInfoObservable
Represents an observable containing metrics on a terminated query.
|
protected UnicastAutoReleaseSubject<ByteBuf> |
YasjlQueryResponseParser.queryProfileInfoObservable
Represents an observable containing profile info on a terminated query.
|
protected UnicastAutoReleaseSubject<ByteBuf> |
YasjlQueryResponseParser.queryRowObservable
Represents an observable that sends result chunks.
|
protected UnicastAutoReleaseSubject<ByteBuf> |
YasjlQueryResponseParser.querySignatureObservable
Represents an observable that has the signature of the N1QL results if there are any.
|
Modifier and Type | Method and Description |
---|---|
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.create(long noSubscriptionTimeout,
TimeUnit timeUnit) |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.create(long noSubscriptionTimeout,
TimeUnit timeUnit,
rx.functions.Action0 onUnsubscribe) |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.create(long noSubscriptionTimeout,
TimeUnit timeUnit,
rx.Scheduler timeoutScheduler) |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.create(long noSubscriptionTimeout,
TimeUnit timeUnit,
rx.Scheduler timeoutScheduler,
rx.functions.Action0 onUnsubscribe) |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.createWithoutNoSubscriptionTimeout()
Creates a new
UnicastAutoReleaseSubject without a no subscription timeout. |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.createWithoutNoSubscriptionTimeout(rx.functions.Action0 onUnsubscribe)
Creates a new
UnicastAutoReleaseSubject without a no subscription timeout. |
UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.withTraceIdentifier(String id) |
Copyright © 2017 Couchbase, Inc.. All rights reserved.