import { QueryBus } from 'ts-eventsourcing/QueryHandling/QueryBus'; import { Observable } from 'rxjs'; import { ServerGatewayMessage } from '../../Gateway/ValueObject/ServerGatewayMessage'; import { ServerGatewayMetadata } from '../../Gateway/ValueObject/ServerGatewayMetadata'; /** * Dispatch gateway messages to the query bus. */ export declare function dispatchClientQueryOnQueryBus(queryBus: QueryBus): (input: Observable>>) => Observable;