Uses of Interface
com.influxdb.Cancellable

Packages that use Cancellable

Package	Description
com.influxdb.client
com.influxdb.client.flux
com.influxdb.client.flux.internal
com.influxdb.client.internal
com.influxdb.internal
com.influxdb.query.internal

Uses of Cancellable in com.influxdb.client

Method parameters in com.influxdb.client with type arguments of type Cancellable

Modifier and Type	Method	Description
<M> void	InvokableScriptsApi.invokeScript(String scriptId, Map<String,Object> params, Class<M> measurementType, BiConsumer<Cancellable,M> onNext)	Executes the script and asynchronously stream POJO classes to onNext consumer.
<M> void	InvokableScriptsApi.invokeScript(String scriptId, Map<String,Object> params, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the script and asynchronously stream POJO classes to onNext consumer.
void	InvokableScriptsApi.invokeScript(String scriptId, Map<String,Object> params, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the script and asynchronously stream FluxRecords to onNext consumer.
void	InvokableScriptsApi.invokeScript(String scriptId, Map<String,Object> params, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the script and asynchronously stream FluxRecords to onNext consumer.
void	InvokableScriptsApi.invokeScriptRaw(String scriptId, Map<String,Object> params, BiConsumer<Cancellable,String> onResponse)	Executes the script and asynchronously stream response (line by line) to onResponse.
void	InvokableScriptsApi.invokeScriptRaw(String scriptId, Map<String,Object> params, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the script and asynchronously stream response (line by line) to onResponse.
<M> void	QueryApi.query(Query query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes to onNext consumer.
<M> void	QueryApi.query(Query query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes to onNext consumer.
<M> void	QueryApi.query(Query query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query and asynchronously stream result as POJO.
<M> void	QueryApi.query(Query query, String org, Class<M> measurementType, BiConsumer<Cancellable,M> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes to onNext consumer.
<M> void	QueryApi.query(Query query, String org, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes to onNext consumer.
<M> void	QueryApi.query(Query query, String org, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query and asynchronously stream result as POJO.
void	QueryApi.query(Query query, String org, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(Query query, String org, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(Query query, String org, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(Query query, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(Query query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(Query query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
<M> void	QueryApi.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes to onNext consumer.
<M> void	QueryApi.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes to onNext consumer.
<M> void	QueryApi.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query and asynchronously stream result as POJO.
<M> void	QueryApi.query(String query, String org, Class<M> measurementType, BiConsumer<Cancellable,M> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes to onNext consumer.
<M> void	QueryApi.query(String query, String org, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes to onNext consumer.
<M> void	QueryApi.query(String query, String org, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query and asynchronously stream result as POJO.
<M> void	QueryApi.query(String query, String org, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete, Map<String,Object> params)	Executes the Parameterized Flux query and asynchronously stream result as POJO.
void	QueryApi.query(String query, String org, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, String org, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, String org, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, String org, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete, Map<String,Object> params)	Executes the Parameterized Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.queryRaw(Query query, String org, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(Query query, String org, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(Query query, String org, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(Query query, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(Query query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(Query query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, Dialect dialect, String org, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, Dialect dialect, String org, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, Dialect dialect, String org, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, Dialect dialect, String org, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete, Map<String,Object> params)	Executes the Parameterized Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, Dialect dialect, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, Dialect dialect, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, Dialect dialect, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, String org, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, String org, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, String org, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, String org, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Map<String,Object> params)	Executes the Parameterized Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.
void	QueryApi.queryRaw(String query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) to onResponse.

Uses of Cancellable in com.influxdb.client.flux

Method parameters in com.influxdb.client.flux with type arguments of type Cancellable

Modifier and Type	Method	Description
<M> void	FluxClient.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext)	Executes the Flux query against the InfluxDB and asynchronously stream POJO classes to onNext consumer.
<M> void	FluxClient.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream POJO classes to onNext consumer.
<M> void	FluxClient.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query and asynchronously stream result as POJO.
void	FluxClient.query(String query, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.
void	FluxClient.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.
void	FluxClient.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.
void	FluxClient.queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	FluxClient.queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	FluxClient.queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	FluxClient.queryRaw(String query, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	FluxClient.queryRaw(String query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	FluxClient.queryRaw(String query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.

Uses of Cancellable in com.influxdb.client.flux.internal

Method parameters in com.influxdb.client.flux.internal with type arguments of type Cancellable

Modifier and Type	Method	Description
<M> void	FluxApiImpl.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext)
<M> void	FluxApiImpl.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError)
<M> void	FluxApiImpl.query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete)
void	FluxApiImpl.query(String query, BiConsumer<Cancellable,FluxRecord> onNext)
void	FluxApiImpl.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)
void	FluxApiImpl.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)
void	FluxApiImpl.queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onNext)
void	FluxApiImpl.queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)
void	FluxApiImpl.queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)
void	FluxApiImpl.queryRaw(String query, BiConsumer<Cancellable,String> onResponse)
void	FluxApiImpl.queryRaw(String query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)
void	FluxApiImpl.queryRaw(String query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)

Uses of Cancellable in com.influxdb.client.internal

Constructors in com.influxdb.client.internal with parameters of type Cancellable

Modifier	Constructor	Description
	ResultsDeserializer(Cancellable cancellable)

Uses of Cancellable in com.influxdb.internal

Method parameters in com.influxdb.internal with type arguments of type Cancellable

Modifier and Type	Method	Description
protected void	AbstractQueryApi.query(retrofit2.Call<okhttp3.ResponseBody> query, BiConsumer<Cancellable,okio.BufferedSource> consumer, Consumer<? super Throwable> onError, Runnable onComplete, Boolean asynchronously)
protected void	AbstractQueryApi.queryRaw(retrofit2.Call<okhttp3.ResponseBody> queryCall, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete, Boolean asynchronously)

Uses of Cancellable in com.influxdb.query.internal

Methods in com.influxdb.query.internal with parameters of type Cancellable

Modifier and Type	Method	Description
void	FluxCsvParser.FluxResponseConsumer.accept(int index, Cancellable cancellable, FluxRecord record)	Add new FluxRecord to consumer.
void	FluxCsvParser.FluxResponseConsumer.accept(int index, Cancellable cancellable, FluxTable table)	Add new FluxTable to consumer.
void	FluxCsvParser.FluxResponseConsumerTable.accept(int index, Cancellable cancellable, FluxRecord record)
void	FluxCsvParser.FluxResponseConsumerTable.accept(int index, Cancellable cancellable, FluxTable table)
void	FluxCsvParser.parseFluxResponse(okio.BufferedSource bufferedSource, Cancellable cancellable, FluxCsvParser.FluxResponseConsumer consumer)	Parse Flux CSV response to FluxCsvParser.FluxResponseConsumer.