{"version":3,"sources":["../../../packages/core/rpc/settings/rpc-settings-subject-server.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,OAAO,EAAE,MAAM,MAAM,CAAC;AAC/B,OAAO,EAAE,YAAY,EAAE,GAAG,EAAE,MAAM,QAAQ,CAAC;AAC3C,OAAO,EAAE,gBAAgB,EAAE,MAAM,uBAAuB,CAAC;AACzD,OAAO,EAAE,kBAAkB,EAAE,MAAM,wBAAwB,CAAC;AAC5D,OAAO,EAAE,WAAW,EAAkB,iBAAiB,EAAE,MAAM,sBAAsB,CAAC;AAEtF;;GAEG;AACH,MAAM,WAAW,kBAAmB,SAAQ,OAAO,CAAC,YAAY,CAAC,WAAW,EAAE,iBAAiB,CAAC,CAAC;CAAG;AAEpG;;GAEG;AACH,qBAAa,wBAAyB,SAAQ,gBAAgB,CAAC,WAAW,EAAE,iBAAiB,CAAE,YAAW,kBAAkB;IACxH;;OAEG;gBACS,GAAG,EAAE,GAAG;IAIpB;;;;;OAKG;IACI,OAAO,CAAC,IAAI,EAAE,WAAW,GAAG,OAAO,CAAC,iBAAiB,CAAC;CAGhE","file":"rpc-settings-subject-server.d.ts","sourcesContent":["import { Subject } from 'rxjs';\r\nimport { DeferredData, Rpc } from '../rpc';\r\nimport { RpcSubjectServer } from '../rpc-subject-server';\r\nimport { RpcSettingsHandler } from './rpc-settings-handler';\r\nimport { RpcSettings, RpcSettingsKey, RpcSettingsResult } from './rpc-settings-model';\r\n\r\n/**\r\n * Rpc settings request subject interface.\r\n */\r\nexport interface RpcSettingsSubject extends Subject<DeferredData<RpcSettings, RpcSettingsResult>> {}\r\n\r\n/**\r\n * The class to implement RpcLog with Subject server.\r\n */\r\nexport class RpcSettingsSubjectServer extends RpcSubjectServer<RpcSettings, RpcSettingsResult> implements RpcSettingsHandler {\r\n    /**\r\n     * Initializes a new instance of the RpcSettingsSubjectServer class.\r\n     */\r\n    constructor(rpc: Rpc) {\r\n        super(rpc, RpcSettingsKey.command);\r\n    }\r\n\r\n    /**\r\n     * The handler to respond a request for RpcLog call.\r\n     *\r\n     * @param data The RPC log record object.\r\n     * @returns return the Promise<void> object.\r\n     */\r\n    public handler(data: RpcSettings): Promise<RpcSettingsResult> {\r\n        return this.processNextForSubject(RpcSettingsKey.command, data);\r\n    }\r\n}\r\n"]}