kafkajs-snappy-typescript
Advanced tools
Comparing version 1.0.2 to 1.0.3
/// <reference types="node" /> | ||
interface IEncoder { | ||
buffer: Buffer; | ||
} | ||
export declare class SnappyCodec { | ||
@@ -11,5 +14,6 @@ private static XERIAL_HEADER; | ||
codec: () => { | ||
compress: (msg: string) => Promise<Buffer>; | ||
compress: (encoder: IEncoder) => Promise<Buffer>; | ||
decompress: (buffer: Buffer) => Promise<string | Buffer>; | ||
}; | ||
} | ||
export {}; |
@@ -28,5 +28,5 @@ "use strict"; | ||
} | ||
compress(msg) { | ||
compress(encoder) { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
return (0, snappy_1.compress)(msg); | ||
return (0, snappy_1.compress)(encoder.buffer); | ||
}); | ||
@@ -33,0 +33,0 @@ } |
{ | ||
"name": "kafkajs-snappy-typescript", | ||
"version": "1.0.2", | ||
"version": "1.0.3", | ||
"description": "Snappy codec for kafkajs in typescript", | ||
@@ -17,3 +17,8 @@ "main": "dist/index.js", | ||
}, | ||
"keywords": ["typescript", "snappy", "kafkajs", "codec"], | ||
"keywords": [ | ||
"typescript", | ||
"snappy", | ||
"kafkajs", | ||
"codec" | ||
], | ||
"license": "MIT", | ||
@@ -36,6 +41,8 @@ "types": "dist/index.d.ts", | ||
}, | ||
"contributors": [{ | ||
"name": "Nicholas RAMSEY", | ||
"url": "https://github.com/nicholas-ramsey" | ||
}] | ||
"contributors": [ | ||
{ | ||
"name": "Nicholas RAMSEY", | ||
"url": "https://github.com/nicholas-ramsey" | ||
} | ||
] | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
6894
94