@InterfaceStability.Committed @InterfaceAudience.Public public class DefaultAsyncN1qlQueryResult extends Object implements AsyncN1qlQueryResult
AsyncN1qlQueryResult
.Constructor and Description |
---|
DefaultAsyncN1qlQueryResult(rx.Observable<AsyncN1qlQueryRow> rows,
rx.Observable<Object> signature,
rx.Observable<N1qlMetrics> info,
rx.Observable<JsonObject> errors,
rx.Observable<JsonObject> profileInfo,
rx.Observable<String> finalStatus,
boolean parsingSuccess,
String requestId,
String clientContextId) |
Modifier and Type | Method and Description |
---|---|
String |
clientContextId() |
rx.Observable<JsonObject> |
errors() |
rx.Observable<Boolean> |
finalSuccess()
Asynchronously denotes the success or failure of the query.
|
rx.Observable<N1qlMetrics> |
info() |
boolean |
parseSuccess()
Immediately denotes initial parsing success of the query.
|
rx.Observable<JsonObject> |
profileInfo() |
String |
requestId() |
rx.Observable<AsyncN1qlQueryRow> |
rows() |
rx.Observable<Object> |
signature() |
rx.Observable<String> |
status()
Asynchronously returns the final status of the query.
|
public DefaultAsyncN1qlQueryResult(rx.Observable<AsyncN1qlQueryRow> rows, rx.Observable<Object> signature, rx.Observable<N1qlMetrics> info, rx.Observable<JsonObject> errors, rx.Observable<JsonObject> profileInfo, rx.Observable<String> finalStatus, boolean parsingSuccess, String requestId, String clientContextId)
public rx.Observable<AsyncN1qlQueryRow> rows()
rows
in interface AsyncN1qlQueryResult
public rx.Observable<Object> signature()
signature
in interface AsyncN1qlQueryResult
row
. This signature is usually a
JsonObject
, but could also be any JSON-valid type like a boolean scalar, JsonArray
...public rx.Observable<N1qlMetrics> info()
info
in interface AsyncN1qlQueryResult
public rx.Observable<JsonObject> profileInfo()
profileInfo
in interface AsyncN1qlQueryResult
public rx.Observable<Boolean> finalSuccess()
AsyncN1qlQueryResult
AsyncN1qlQueryResult.parseSuccess()
, for example if a fatal error comes up while streaming the results
to the client. Receiving a (single) value for finalSuccess means the query is over.finalSuccess
in interface AsyncN1qlQueryResult
public rx.Observable<String> status()
AsyncN1qlQueryResult
success
" (which is equivalent to AsyncN1qlQueryResult.finalSuccess()
returning true). Other statuses include
(but are not limited to) "fatal
" when fatal errors occurred and "timeout
" when the
query timed out on the server side but not yet on the client side. Receiving a (single) value for status means
the query is over.status
in interface AsyncN1qlQueryResult
public boolean parseSuccess()
AsyncN1qlQueryResult
AsyncN1qlQueryResult.finalSuccess()
for the end of processing status.parseSuccess
in interface AsyncN1qlQueryResult
public rx.Observable<JsonObject> errors()
errors
in interface AsyncN1qlQueryResult
public String requestId()
requestId
in interface AsyncN1qlQueryResult
public String clientContextId()
clientContextId
in interface AsyncN1qlQueryResult
Copyright © 2015 Couchbase, Inc.