1 |
|
2 | import { Call, StatusObject, WriteObject } from './call-stream';
|
3 | import { Metadata } from './metadata';
|
4 |
|
5 |
|
6 |
|
7 |
|
8 | export interface Filter {
|
9 | sendMetadata(metadata: Promise<Metadata>): Promise<Metadata>;
|
10 | receiveMetadata(metadata: Metadata): Metadata;
|
11 | sendMessage(message: Promise<WriteObject>): Promise<WriteObject>;
|
12 | receiveMessage(message: Promise<Buffer>): Promise<Buffer>;
|
13 | receiveTrailers(status: StatusObject): StatusObject;
|
14 | }
|
15 | export declare abstract class BaseFilter implements Filter {
|
16 | sendMetadata(metadata: Promise<Metadata>): Promise<Metadata>;
|
17 | receiveMetadata(metadata: Metadata): Metadata;
|
18 | sendMessage(message: Promise<WriteObject>): Promise<WriteObject>;
|
19 | receiveMessage(message: Promise<Buffer>): Promise<Buffer>;
|
20 | receiveTrailers(status: StatusObject): StatusObject;
|
21 | }
|
22 | export interface FilterFactory<T extends Filter> {
|
23 | createFilter(callStream: Call): T;
|
24 | }
|