1 |
|
2 | import { CallCredentials } from './call-credentials';
|
3 | import { Call, CallStreamOptions, InterceptingListener, MessageContext, StatusObject } from './call-interface';
|
4 | import { Status } from './constants';
|
5 | import { FilterStackFactory } from './filter-stack';
|
6 | import { InternalChannel } from './internal-channel';
|
7 | import { Metadata } from './metadata';
|
8 | export declare class ResolvingCall implements Call {
|
9 | private readonly channel;
|
10 | private readonly method;
|
11 | private readonly filterStackFactory;
|
12 | private credentials;
|
13 | private callNumber;
|
14 | private child;
|
15 | private readPending;
|
16 | private pendingMessage;
|
17 | private pendingHalfClose;
|
18 | private ended;
|
19 | private readFilterPending;
|
20 | private writeFilterPending;
|
21 | private pendingChildStatus;
|
22 | private metadata;
|
23 | private listener;
|
24 | private deadline;
|
25 | private host;
|
26 | private statusWatchers;
|
27 | private deadlineTimer;
|
28 | private filterStack;
|
29 | constructor(channel: InternalChannel, method: string, options: CallStreamOptions, filterStackFactory: FilterStackFactory, credentials: CallCredentials, callNumber: number);
|
30 | private trace;
|
31 | private runDeadlineTimer;
|
32 | private outputStatus;
|
33 | private sendMessageOnChild;
|
34 | getConfig(): void;
|
35 | reportResolverError(status: StatusObject): void;
|
36 | cancelWithStatus(status: Status, details: string): void;
|
37 | getPeer(): string;
|
38 | start(metadata: Metadata, listener: InterceptingListener): void;
|
39 | sendMessageWithContext(context: MessageContext, message: Buffer): void;
|
40 | startRead(): void;
|
41 | halfClose(): void;
|
42 | setCredentials(credentials: CallCredentials): void;
|
43 | addStatusWatcher(watcher: (status: StatusObject) => void): void;
|
44 | getCallNumber(): number;
|
45 | }
|