1 |
|
2 | import { EventEmitter } from 'events';
|
3 | import { Duplex, Readable, Writable } from 'stream';
|
4 | import { StatusObject } from './call-stream';
|
5 | import { EmitterAugmentation1 } from './events';
|
6 | import { Metadata } from './metadata';
|
7 | import { ObjectReadable, ObjectWritable, WriteCallback } from './object-stream';
|
8 | import { InterceptingCallInterface } from './client-interceptors';
|
9 |
|
10 |
|
11 |
|
12 | export declare type ServiceError = StatusObject & Error;
|
13 |
|
14 |
|
15 |
|
16 | export declare type SurfaceCall = {
|
17 | call?: InterceptingCallInterface;
|
18 | cancel(): void;
|
19 | getPeer(): string;
|
20 | } & EmitterAugmentation1<'metadata', Metadata> & EmitterAugmentation1<'status', StatusObject> & EventEmitter;
|
21 |
|
22 |
|
23 |
|
24 | export declare type ClientUnaryCall = SurfaceCall;
|
25 |
|
26 |
|
27 |
|
28 | export declare type ClientReadableStream<ResponseType> = {
|
29 | deserialize: (chunk: Buffer) => ResponseType;
|
30 | } & SurfaceCall & ObjectReadable<ResponseType>;
|
31 |
|
32 |
|
33 |
|
34 | export declare type ClientWritableStream<RequestType> = {
|
35 | serialize: (value: RequestType) => Buffer;
|
36 | } & SurfaceCall & ObjectWritable<RequestType>;
|
37 |
|
38 |
|
39 |
|
40 | export declare type ClientDuplexStream<RequestType, ResponseType> = ClientWritableStream<RequestType> & ClientReadableStream<ResponseType>;
|
41 |
|
42 |
|
43 |
|
44 |
|
45 |
|
46 |
|
47 | export declare function callErrorFromStatus(status: StatusObject): ServiceError;
|
48 | export declare class ClientUnaryCallImpl extends EventEmitter implements ClientUnaryCall {
|
49 | call?: InterceptingCallInterface;
|
50 | constructor();
|
51 | cancel(): void;
|
52 | getPeer(): string;
|
53 | }
|
54 | export declare class ClientReadableStreamImpl<ResponseType> extends Readable implements ClientReadableStream<ResponseType> {
|
55 | readonly deserialize: (chunk: Buffer) => ResponseType;
|
56 | call?: InterceptingCallInterface;
|
57 | constructor(deserialize: (chunk: Buffer) => ResponseType);
|
58 | cancel(): void;
|
59 | getPeer(): string;
|
60 | _read(_size: number): void;
|
61 | }
|
62 | export declare class ClientWritableStreamImpl<RequestType> extends Writable implements ClientWritableStream<RequestType> {
|
63 | readonly serialize: (value: RequestType) => Buffer;
|
64 | call?: InterceptingCallInterface;
|
65 | constructor(serialize: (value: RequestType) => Buffer);
|
66 | cancel(): void;
|
67 | getPeer(): string;
|
68 | _write(chunk: RequestType, encoding: string, cb: WriteCallback): void;
|
69 | _final(cb: Function): void;
|
70 | }
|
71 | export declare class ClientDuplexStreamImpl<RequestType, ResponseType> extends Duplex implements ClientDuplexStream<RequestType, ResponseType> {
|
72 | readonly serialize: (value: RequestType) => Buffer;
|
73 | readonly deserialize: (chunk: Buffer) => ResponseType;
|
74 | call?: InterceptingCallInterface;
|
75 | constructor(serialize: (value: RequestType) => Buffer, deserialize: (chunk: Buffer) => ResponseType);
|
76 | cancel(): void;
|
77 | getPeer(): string;
|
78 | _read(_size: number): void;
|
79 | _write(chunk: RequestType, encoding: string, cb: WriteCallback): void;
|
80 | _final(cb: Function): void;
|
81 | }
|