UNPKG

1.75 kBTypeScriptView Raw
1/// <reference types="node" />
2import { CallCredentials } from './call-credentials';
3import { Call, CallStreamOptions, InterceptingListener, MessageContext, StatusObject } from './call-interface';
4import { Status } from './constants';
5import { FilterStackFactory } from './filter-stack';
6import { InternalChannel } from './internal-channel';
7import { Metadata } from './metadata';
8export 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}