| 1 |
|
| 2 | import { Call, WriteObject } from './call-stream';
|
| 3 | import { Channel } from './channel';
|
| 4 | import { BaseFilter, Filter, FilterFactory } from './filter';
|
| 5 | import { Metadata } from './metadata';
|
| 6 | export declare class CompressionFilter extends BaseFilter implements Filter {
|
| 7 | private sendCompression;
|
| 8 | private receiveCompression;
|
| 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 | }
|
| 14 | export declare class CompressionFilterFactory implements FilterFactory<CompressionFilter> {
|
| 15 | private readonly channel;
|
| 16 | constructor(channel: Channel);
|
| 17 | createFilter(callStream: Call): CompressionFilter;
|
| 18 | }
|