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}