diff options
| author | altaf-creator <dev@altafcreator.com> | 2025-11-09 11:15:19 +0800 |
|---|---|---|
| committer | altaf-creator <dev@altafcreator.com> | 2025-11-09 11:15:19 +0800 |
| commit | 8eff962cab608341a6f2fedc640a0e32d96f26e2 (patch) | |
| tree | 05534d1a720ddc3691d346c69b4972555820a061 /frontend-old/node_modules/@grpc/grpc-js/src/object-stream.ts | |
pain
Diffstat (limited to 'frontend-old/node_modules/@grpc/grpc-js/src/object-stream.ts')
| -rw-r--r-- | frontend-old/node_modules/@grpc/grpc-js/src/object-stream.ts | 66 |
1 files changed, 66 insertions, 0 deletions
diff --git a/frontend-old/node_modules/@grpc/grpc-js/src/object-stream.ts b/frontend-old/node_modules/@grpc/grpc-js/src/object-stream.ts new file mode 100644 index 0000000..49ef1f3 --- /dev/null +++ b/frontend-old/node_modules/@grpc/grpc-js/src/object-stream.ts @@ -0,0 +1,66 @@ +/* + * Copyright 2019 gRPC authors. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { Readable, Writable } from 'stream'; +import { EmitterAugmentation1 } from './events'; + +/* eslint-disable @typescript-eslint/no-explicit-any */ + +export type WriteCallback = (error: Error | null | undefined) => void; + +export interface IntermediateObjectReadable<T> extends Readable { + read(size?: number): any & T; +} + +export type ObjectReadable<T> = { + read(size?: number): T; +} & EmitterAugmentation1<'data', T> & + IntermediateObjectReadable<T>; + +export interface IntermediateObjectWritable<T> extends Writable { + _write(chunk: any & T, encoding: string, callback: Function): void; + write(chunk: any & T, cb?: WriteCallback): boolean; + write(chunk: any & T, encoding?: any, cb?: WriteCallback): boolean; + setDefaultEncoding(encoding: string): this; + end(): ReturnType<Writable['end']> extends Writable ? this : void; + end( + chunk: any & T, + cb?: Function + ): ReturnType<Writable['end']> extends Writable ? this : void; + end( + chunk: any & T, + encoding?: any, + cb?: Function + ): ReturnType<Writable['end']> extends Writable ? this : void; +} + +export interface ObjectWritable<T> extends IntermediateObjectWritable<T> { + _write(chunk: T, encoding: string, callback: Function): void; + write(chunk: T, cb?: Function): boolean; + write(chunk: T, encoding?: any, cb?: Function): boolean; + setDefaultEncoding(encoding: string): this; + end(): ReturnType<Writable['end']> extends Writable ? this : void; + end( + chunk: T, + cb?: Function + ): ReturnType<Writable['end']> extends Writable ? this : void; + end( + chunk: T, + encoding?: any, + cb?: Function + ): ReturnType<Writable['end']> extends Writable ? this : void; +} |
