import { Observable, ObservableInput } from 'rxjs'; import { ServerGatewayMessage } from '../../Gateway/ValueObject/ServerGatewayMessage'; import { ServerGatewayMetadata } from '../../Gateway/ValueObject/ServerGatewayMetadata'; import { ServerGatewayInterface } from '../../Gateway/ServerGatewayInterface'; /** * Helper transformation operator with client gateways. * * @example * * fromClientCommand((clientGateway) => { * return (clientGateway, messages$) => { * // clientGateway.emit() * // Return some observable * return messages$; * }; * }) */ export declare function fromClientCommand, Message extends ServerGatewayMessage>>(callback: (clientGateway: ClientGateway, message: Message) => () => ObservableInput): (input: Observable) => Observable;