import { ClientDuplexStream, ClientReadableStream } from 'grpc';
import { Observable } from 'rxjs';
export declare function duplexStreamToObservable<A extends {
    setNumberOfPermits(permits: number): void;
}, B extends {
    toObject(): any;
}>(call: ClientDuplexStream<A, B>, request: A, Response: new () => B, numberOfPermits: number): Observable<B>;
export declare function readStreamToPromise<A, B extends {
    toObject(): any;
}>(callThunk: () => ClientReadableStream<B>, Response: new () => B, initialData: A, transformData: (data: A, payload: B) => A): Promise<A>;