@avro/streams
Advanced tools
@@ -129,2 +129,3 @@ /* jshint node: true */ | ||
| allowHalfOpen: true, // For async decompressors. | ||
| autoDestroy: opts.autoDestroy, | ||
| readableObjectMode: !noDecode | ||
@@ -396,2 +397,3 @@ }); | ||
| allowHalfOpen: true, // To support async compressors. | ||
| autoDestroy: opts.autoDestroy, | ||
| writableObjectMode: true | ||
@@ -398,0 +400,0 @@ }); |
+7
-5
@@ -15,3 +15,4 @@ import {Schema, Type} from '@avro/types'; | ||
| export interface BlockDecoderOpts { | ||
| readonly codecs?: {[key: string]: Codec}; | ||
| readonly autoDestroy?: boolean; | ||
| readonly codecs?: {readonly [key: string]: Codec}; | ||
| readonly parseHook?: (schema: Schema) => Schema; | ||
@@ -28,8 +29,9 @@ readonly readerSchema?: Schema; | ||
| export interface BlockEncoderOpts { | ||
| readonly autoDestroy?: boolean; | ||
| readonly blockSize?: number; | ||
| readonly check?: boolean | Type.CheckValidOpts; | ||
| readonly codec?: string; | ||
| readonly codecs?: {[key: string]: Codec}; | ||
| readonly metadata?: {[key: string]: Buffer}; | ||
| readonly check?: boolean | Type.CheckValidOpts; | ||
| readonly omitHeader?: boolean; | ||
| readonly codecs?: {readonly [key: string]: Codec}; | ||
| readonly metadata?: {readonly [key: string]: Buffer}; | ||
| readonly writeHeader?: boolean | 'never' | 'auto' | 'always'; | ||
| } | ||
@@ -36,0 +38,0 @@ |
+1
-1
| { | ||
| "name": "@avro/streams", | ||
| "version": "1.0.10", | ||
| "version": "1.0.11", | ||
| "description": "Avro data streams", | ||
@@ -5,0 +5,0 @@ "homepage": "https://github.com/mtth/avsc", |
26314
0.75%805
0.5%