@@ -5,6 +5,12 @@ const buffer = require('buffer');
5
5
6
6
describe ( 'Browser tests' , function ( ) {
7
7
describe ( 'reader' , function ( ) {
8
+ let reader ;
9
+
10
+ after ( async function ( ) {
11
+ if ( reader ) await reader . close ( ) ;
12
+ } ) ;
13
+
8
14
it ( 'can read snappy compressed data' , async function ( ) {
9
15
// Data from test/test-files/snappy-compressed.parquet
10
16
const uint8Array = [
@@ -25,16 +31,12 @@ describe('Browser tests', function () {
25
31
101 , 116 , 106 , 115 , 0 , 163 , 0 , 0 , 0 , 80 , 65 , 82 , 49 ,
26
32
] ;
27
33
const snappyCompressedBuffer = buffer . Buffer . from ( uint8Array ) ;
28
- const reader = await parquetjs . ParquetReader . openBuffer ( snappyCompressedBuffer ) ;
34
+ reader = await parquetjs . ParquetReader . openBuffer ( snappyCompressedBuffer ) ;
29
35
const data : any [ ] = [ ] ;
30
36
for await ( const record of reader ) {
31
37
data . push ( record ) ;
32
38
}
33
39
assert . equal ( data . length , 4 ) ;
34
-
35
- after ( async function ( ) {
36
- await reader . close ( ) ;
37
- } ) ;
38
40
} ) ;
39
41
40
42
it ( 'can read gzip compressed data' , async function ( ) {
@@ -110,16 +112,12 @@ describe('Browser tests', function () {
110
112
57 , 100 , 53 , 53 , 97 , 51 , 41 , 0 , 71 , 1 , 0 , 0 , 80 , 65 , 82 , 49 ,
111
113
] ;
112
114
const gzipCompressedBuffer = buffer . Buffer . from ( uint8Array ) ;
113
- const reader = await parquetjs . ParquetReader . openBuffer ( gzipCompressedBuffer ) ;
115
+ reader = await parquetjs . ParquetReader . openBuffer ( gzipCompressedBuffer ) ;
114
116
const data : any [ ] = [ ] ;
115
117
for await ( const record of reader ) {
116
118
data . push ( record ) ;
117
119
}
118
120
assert . equal ( data . length , 25 ) ;
119
-
120
- after ( async function ( ) {
121
- await reader . close ( ) ;
122
- } ) ;
123
121
} ) ;
124
122
125
123
it ( 'can read brotli compressed data' , async function ( ) {
@@ -233,15 +231,12 @@ describe('Browser tests', function () {
233
231
80 , 65 , 82 , 49 ,
234
232
] ;
235
233
const brotliCompressedBuffer = buffer . Buffer . from ( uint8Array ) ;
236
- const reader = await parquetjs . ParquetReader . openBuffer ( brotliCompressedBuffer ) ;
234
+ reader = await parquetjs . ParquetReader . openBuffer ( brotliCompressedBuffer ) ;
237
235
const data : any [ ] = [ ] ;
238
236
for await ( const record of reader ) {
239
237
data . push ( record ) ;
240
238
}
241
239
assert . equal ( data . length , 5 ) ;
242
- after ( async function ( ) {
243
- await reader . close ( ) ;
244
- } ) ;
245
240
} ) ;
246
241
} ) ;
247
242
} ) ;
0 commit comments