{"version":3,"sources":["../../../packages/core/rpc/alive/rpc-observable-alive-client.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAE,MAAM,MAAM,CAAC;AAClC,OAAO,EAAE,GAAG,EAAE,MAAM,QAAQ,CAAC;AAC7B,OAAO,EAAE,mBAAmB,EAAE,MAAM,0BAA0B,CAAC;AAC/D,OAAO,EAAE,WAAW,EAAE,MAAM,iBAAiB,CAAC;AAC9C,OAAO,EACH,uBAAuB,EAAyB,yBAAyB,EAAE,wBAAwB,EACtG,MAAM,8BAA8B,CAAC;AAEtC,qBAAa,wBACT,SAAQ,mBAAmB,CAAC,yBAAyB,EAAE,wBAAwB,EAAE,uBAAuB,CAAC;IAEzG;;;;OAIG;gBACS,GAAG,EAAE,GAAG;IAIpB;;;;;;OAMG;IACI,KAAK,CAAC,OAAO,CAAC,EAAE,yBAAyB,EAAE,QAAQ,CAAC,EAAE,WAAW,GAAG,UAAU,CAAC,wBAAwB,CAAC;IAU/G;;;;;OAKG;IACI,OAAO,CAAC,QAAQ,CAAC,EAAE,WAAW,GAAG,UAAU,CAAC,wBAAwB,CAAC;IAQ5E;;;;;OAKG;IACI,KAAK,CAAC,QAAQ,CAAC,EAAE,WAAW,GAAG,UAAU,CAAC,wBAAwB,CAAC;CAO7E","file":"rpc-observable-alive-client.d.ts","sourcesContent":["import { Observable } from 'rxjs';\r\nimport { Rpc } from '../rpc';\r\nimport { RpcObservableClient } from '../rpc-observable-client';\r\nimport { RpcOutbound } from '../rpc-outbound';\r\nimport {\r\n    RpcObservableAliveError, RpcObservableAliveKey, RpcObservableAliveRequest, RpcObservableAliveResult\r\n} from './rpc-observable-alive-model';\r\n\r\nexport class RpcObservableAliveClient\r\n    extends RpcObservableClient<RpcObservableAliveRequest, RpcObservableAliveResult, RpcObservableAliveError>  {\r\n\r\n    /**\r\n     * Initializes a new instance of the RpcObservableAliveClient class.\r\n     *\r\n     * @param rpc the rpc object.\r\n     */\r\n    constructor(rpc: Rpc) {\r\n        super(rpc, RpcObservableAliveKey.command, RpcObservableAliveKey.version);\r\n    }\r\n\r\n    /**\r\n     * The alive command.\r\n     *\r\n     * @param request the Rpc alive data object.\r\n     * @param outbound the Rpc outbound channel object.\r\n     * @return Observable<RpcObservableAliveResult> the observable object.\r\n     */\r\n    public alive(request?: RpcObservableAliveRequest, outbound?: RpcOutbound): Observable<RpcObservableAliveResult> {\r\n        if (!request) {\r\n            request = {\r\n                timestamp: Date.now()\r\n            };\r\n        }\r\n\r\n        return this.observableCall(request, outbound);\r\n    }\r\n\r\n    /**\r\n     * The alive forever command.\r\n     *\r\n     * @param outbound the Rpc outbound channel object.\r\n     * @return Observable<RpcObservableAliveResult> the observable object.\r\n     */\r\n    public forever(outbound?: RpcOutbound): Observable<RpcObservableAliveResult> {\r\n        const request: RpcObservableAliveRequest = {\r\n            timestamp: Date.now(),\r\n            forever: true\r\n        };\r\n        return this.observableCall(request, outbound);\r\n    }\r\n\r\n    /**\r\n     * The reset forever state command.\r\n     *\r\n     * @param outbound the Rpc outbound channel object.\r\n     * @return Observable<RpcObservableAliveResult> the observable object.\r\n     */\r\n    public reset(outbound?: RpcOutbound): Observable<RpcObservableAliveResult> {\r\n        const request: RpcObservableAliveRequest = {\r\n            timestamp: Date.now(),\r\n            forever: false\r\n        };\r\n        return this.observableCall(request, outbound);\r\n    }\r\n}\r\n"]}