Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@aws-sdk/eventstream-serde-universal

Package Overview
Dependencies
Maintainers
5
Versions
107
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@aws-sdk/eventstream-serde-universal - npm Package Compare versions

Comparing version 3.168.0 to 3.170.0

8

CHANGELOG.md

@@ -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 @@

30

dist-types/ts3.4/EventStreamMarshaller.d.ts

@@ -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",

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc