Skip to content

Commit 43b7dec

Browse files
Allow cancellation of tiledb queries
1 parent fe56fd1 commit 43b7dec

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

src/TileDBQuery/TileDBQuery.ts

+4-1
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,7 @@ export class TileDBQuery {
147147
undefined,
148148
undefined,
149149
{
150+
cancelToken: options.cancelToken,
150151
headers: {
151152
'Content-Type': 'application/capnp'
152153
},
@@ -210,7 +211,8 @@ export class TileDBQuery {
210211
ignoreOffsets: body.ignoreOffsets,
211212
attributes: body.attributes,
212213
returnOffsets: body.returnOffsets,
213-
returnRawBuffers: body.returnRawBuffers
214+
returnRawBuffers: body.returnRawBuffers,
215+
cancelToken: body.cancelToken
214216
};
215217
/**
216218
* Get the query response in capnp, we set responseType to arraybuffer instead of JSON
@@ -227,6 +229,7 @@ export class TileDBQuery {
227229
undefined,
228230
undefined,
229231
{
232+
cancelToken: body.cancelToken,
230233
headers: {
231234
'Content-Type': 'application/capnp'
232235
},

src/utils/getResultsFromArrayBuffer.ts

+5
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ import setNullables from './setNullables';
77
import groupValuesByOffsetBytes from './groupValuesByOffsetBytes';
88
import concatChars from './concatChars';
99
import convertToArray from './convertToArray';
10+
import { CancelToken } from 'axios';
1011

1112
export interface Options {
1213
/**
@@ -31,6 +32,10 @@ export interface Options {
3132
* Return offsets for every var-length attribute
3233
*/
3334
returnOffsets?: boolean;
35+
/**
36+
* CancelToken
37+
*/
38+
cancelToken?: CancelToken;
3439
}
3540

3641
type Result =

0 commit comments

Comments
 (0)