@aws-sdk/eventstream-serde-universal
Advanced tools
Comparing version 3.168.0 to 3.170.0
@@ -6,2 +6,10 @@ # Change Log | ||
# [3.170.0](https://github.com/aws/aws-sdk-js-v3/compare/v3.169.0...v3.170.0) (2022-09-13) | ||
**Note:** Version bump only for package @aws-sdk/eventstream-serde-universal | ||
# [3.168.0](https://github.com/aws/aws-sdk-js-v3/compare/v3.167.0...v3.168.0) (2022-09-09) | ||
@@ -8,0 +16,0 @@ |
@@ -1,14 +0,24 @@ | ||
import { Decoder, Encoder, EventStreamMarshaller as IEventStreamMarshaller, Message } from "@aws-sdk/types"; | ||
export interface EventStreamMarshaller extends IEventStreamMarshaller { | ||
} | ||
import { | ||
Decoder, | ||
Encoder, | ||
EventStreamMarshaller as IEventStreamMarshaller, | ||
Message, | ||
} from "@aws-sdk/types"; | ||
export interface EventStreamMarshaller extends IEventStreamMarshaller {} | ||
export interface EventStreamMarshallerOptions { | ||
utf8Encoder: Encoder; | ||
utf8Decoder: Decoder; | ||
utf8Encoder: Encoder; | ||
utf8Decoder: Decoder; | ||
} | ||
export declare class EventStreamMarshaller { | ||
private readonly eventStreamCodec; | ||
private readonly utfEncoder; | ||
constructor({ utf8Encoder, utf8Decoder }: EventStreamMarshallerOptions); | ||
deserialize<T>(body: AsyncIterable<Uint8Array>, deserializer: (input: Record<string, Message>) => Promise<T>): AsyncIterable<T>; | ||
serialize<T>(input: AsyncIterable<T>, serializer: (event: T) => Message): AsyncIterable<Uint8Array>; | ||
private readonly eventStreamCodec; | ||
private readonly utfEncoder; | ||
constructor({ utf8Encoder, utf8Decoder }: EventStreamMarshallerOptions); | ||
deserialize<T>( | ||
body: AsyncIterable<Uint8Array>, | ||
deserializer: (input: Record<string, Message>) => Promise<T> | ||
): AsyncIterable<T>; | ||
serialize<T>( | ||
input: AsyncIterable<T>, | ||
serializer: (event: T) => Message | ||
): AsyncIterable<Uint8Array>; | ||
} |
@@ -1,2 +0,1 @@ | ||
export declare const recordEventMessage: Buffer; | ||
@@ -3,0 +2,0 @@ export declare const statsEventMessage: Buffer; |
@@ -1,15 +0,14 @@ | ||
import { Readable, ReadableOptions } from "stream"; | ||
export interface MockEventMessageSourceOptions extends ReadableOptions { | ||
messages: Array<Buffer>; | ||
emitSize: number; | ||
throwError?: Error; | ||
messages: Array<Buffer>; | ||
emitSize: number; | ||
throwError?: Error; | ||
} | ||
export declare class MockEventMessageSource extends Readable { | ||
private readonly data; | ||
private readonly emitSize; | ||
private readonly throwError?; | ||
private readCount; | ||
constructor(options: MockEventMessageSourceOptions); | ||
_read(): void; | ||
private readonly data; | ||
private readonly emitSize; | ||
private readonly throwError?; | ||
private readCount; | ||
constructor(options: MockEventMessageSourceOptions); | ||
_read(): void; | ||
} |
@@ -1,1 +0,3 @@ | ||
export declare function getChunkedStream(source: AsyncIterable<Uint8Array>): AsyncIterable<Uint8Array>; | ||
export declare function getChunkedStream( | ||
source: AsyncIterable<Uint8Array> | ||
): AsyncIterable<Uint8Array>; |
import { EventStreamCodec } from "@aws-sdk/eventstream-codec"; | ||
import { Encoder, Message } from "@aws-sdk/types"; | ||
export declare type UnmarshalledStreamOptions<T> = { | ||
eventStreamCodec: EventStreamCodec; | ||
deserializer: (input: Record<string, Message>) => Promise<T>; | ||
toUtf8: Encoder; | ||
eventStreamCodec: EventStreamCodec; | ||
deserializer: (input: Record<string, Message>) => Promise<T>; | ||
toUtf8: Encoder; | ||
}; | ||
export declare function getUnmarshalledStream<T extends Record<string, any>>(source: AsyncIterable<Uint8Array>, options: UnmarshalledStreamOptions<T>): AsyncIterable<T>; | ||
export declare function getUnmarshalledStream<T extends Record<string, any>>( | ||
source: AsyncIterable<Uint8Array>, | ||
options: UnmarshalledStreamOptions<T> | ||
): AsyncIterable<T>; |
export * from "./EventStreamMarshaller"; | ||
export * from "./provider"; |
import { EventStreamSerdeProvider } from "@aws-sdk/types"; | ||
export declare const eventStreamSerdeProvider: EventStreamSerdeProvider; |
{ | ||
"name": "@aws-sdk/eventstream-serde-universal", | ||
"version": "3.168.0", | ||
"version": "3.170.0", | ||
"scripts": { | ||
@@ -23,12 +23,12 @@ "build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types'", | ||
"dependencies": { | ||
"@aws-sdk/eventstream-codec": "3.168.0", | ||
"@aws-sdk/types": "3.168.0", | ||
"@aws-sdk/eventstream-codec": "3.170.0", | ||
"@aws-sdk/types": "3.170.0", | ||
"tslib": "^2.3.1" | ||
}, | ||
"devDependencies": { | ||
"@aws-sdk/util-utf8-node": "3.168.0", | ||
"@aws-sdk/util-utf8-node": "3.170.0", | ||
"@tsconfig/recommended": "1.0.1", | ||
"@types/node": "^10.0.0", | ||
"concurrently": "7.0.0", | ||
"downlevel-dts": "0.7.0", | ||
"downlevel-dts": "0.10.1", | ||
"rimraf": "3.0.2", | ||
@@ -35,0 +35,0 @@ "typedoc": "0.19.2", |
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
57486
600
+ Added@aws-sdk/eventstream-codec@3.170.0(transitive)
+ Added@aws-sdk/types@3.170.0(transitive)
+ Added@aws-sdk/util-hex-encoding@3.170.0(transitive)
- Removed@aws-sdk/eventstream-codec@3.168.0(transitive)
- Removed@aws-sdk/types@3.168.0(transitive)
- Removed@aws-sdk/util-hex-encoding@3.168.0(transitive)
Updated@aws-sdk/types@3.170.0