msgpack-javascript/src/decodeAsync.ts at master · somebee/msgpack-javascript · GitHub

History

60 lines (52 loc) · 1.85 KB

Raw

import { Decoder } from "./Decoder";

import { defaultDecodeOptions, DecodeOptions } from "./decode";

import { ensureAsyncIterabe, ReadableStreamLike } from "./utils/stream";

import { SplitUndefined } from "./context";

export async function decodeAsync<ContextType>(

streamLike: ReadableStreamLike<ArrayLike<number>>,

options: DecodeOptions<SplitUndefined<ContextType>> = defaultDecodeOptions as any,

): Promise<unknown> {

const stream = ensureAsyncIterabe(streamLike);

const decoder = new Decoder<ContextType>(

options.extensionCodec,

(options as typeof options & { context: any }).context,

options.maxStrLength,

options.maxBinLength,

options.maxArrayLength,

options.maxMapLength,

options.maxExtLength,

);

return decoder.decodeAsync(stream);

}

export function decodeArrayStream<ContextType>(

streamLike: ReadableStreamLike<ArrayLike<number>>,

options: DecodeOptions<SplitUndefined<ContextType>> = defaultDecodeOptions as any,

) {

const stream = ensureAsyncIterabe(streamLike);

const decoder = new Decoder<ContextType>(

options.extensionCodec,

(options as typeof options & { context: any }).context,

options.maxStrLength,

options.maxBinLength,

options.maxArrayLength,

options.maxMapLength,

options.maxExtLength,

);

return decoder.decodeArrayStream(stream);

}

export function decodeStream<ContextType>(

streamLike: ReadableStreamLike<ArrayLike<number>>,

options: DecodeOptions<SplitUndefined<ContextType>> = defaultDecodeOptions as any,

) {

const stream = ensureAsyncIterabe(streamLike);

const decoder = new Decoder<ContextType>(

options.extensionCodec,

(options as typeof options & { context: any }).context,

options.maxStrLength,

options.maxBinLength,

options.maxArrayLength,

options.maxMapLength,

options.maxExtLength,

);

return decoder.decodeStream(stream);

}

msgpack-javascript/src/decodeAsync.ts at master · somebee/msgpack-javascript · GitHub

Expand file tree

Breadcrumbs

decodeAsync.ts

Latest commit

History

Breadcrumbs

decodeAsync.ts

File metadata and controls