import * as grpc from '@grpc/grpc-js'; import { Observable } from 'rxjs'; /** Optional return value type of reactive server methods with unary responses. */ export interface ReactiveServerUnaryResponse { value: ResponseType; trailer?: grpc.Metadata; flags?: number; } /** Reactive signature for server methods with unary request and response types. */ export declare type ReactiveServerUnaryMethod = (request: RequestType, call: grpc.ServerUnaryCall) => Promise>; /** Reactive signature for server methods with streaming request and unary response types. */ export declare type ReactiveServerRequestStreamMethod = (request: Observable, call: grpc.ServerReadableStream) => Promise>; /** Reactive signature for server methods with unary request and streaming response types. */ export declare type ReactiveServerResponseStreamMethod = (request: RequestType, call: grpc.ServerWritableStream) => Observable; /** Reactive signature for server methods with streaming request and response types. */ export declare type ReactiveServerBidirectionalStreamMethod = (request: Observable, call: grpc.ServerDuplexStream) => Observable; /** Reactive signature for all server methods. */ export declare type ReactiveServerMethod = ReactiveServerUnaryMethod | ReactiveServerRequestStreamMethod | ReactiveServerResponseStreamMethod | ReactiveServerBidirectionalStreamMethod;