UNPKG

1.24 kBTypeScriptView Raw
1/// <reference types="node" />
2import { Call, WriteObject } from './call-stream';
3import { Channel } from './channel';
4import { ChannelOptions } from './channel-options';
5import { BaseFilter, Filter, FilterFactory } from './filter';
6import { Metadata } from './metadata';
7declare type SharedCompressionFilterConfig = {
8 serverSupportedEncodingHeader?: string;
9};
10export declare class CompressionFilter extends BaseFilter implements Filter {
11 private sharedFilterConfig;
12 private sendCompression;
13 private receiveCompression;
14 private currentCompressionAlgorithm;
15 constructor(channelOptions: ChannelOptions, sharedFilterConfig: SharedCompressionFilterConfig);
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}
21export declare class CompressionFilterFactory implements FilterFactory<CompressionFilter> {
22 private readonly channel;
23 private readonly options;
24 private sharedFilterConfig;
25 constructor(channel: Channel, options: ChannelOptions);
26 createFilter(callStream: Call): CompressionFilter;
27}
28export {};