{"version":3,"sources":["../../../packages/core/rpc/extension-broker/rpc-extension-broker-module-request-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,sBAAsB,EAAE,MAAM,8BAA8B,CAAC;AACtE,OAAO,EAAE,yBAAyB,EAAgC,MAAM,8BAA8B,CAAC;AACvG,OAAO,EAAE,gCAAgC,EAAE,MAAM,wCAAwC,CAAC;AAE1F;;GAEG;AACH,MAAM,WAAW,+BAAgC,SAAQ,OAAO,CAAC,YAAY,CAAC,yBAAyB,EAAE,IAAI,CAAC,CAAC;CAAG;AAElH;;GAEG;AACH,qBAAa,qCACL,SAAQ,sBAAsB,CAAC,yBAAyB,EAAE,IAAI,CAC9D,YAAW,gCAAgC;IAE/C;;OAEG;gBACS,GAAG,EAAE,GAAG;IAIpB;;;;;OAKG;IACI,OAAO,CAAC,IAAI,EAAE,yBAAyB,GAAG,OAAO,CAAC,IAAI,CAAC;CAGjE","file":"rpc-extension-broker-module-request-subject-server.d.ts","sourcesContent":["import { Subject } from 'rxjs';\r\nimport { DeferredData, Rpc } from '../rpc';\r\nimport { RpcModuleSubjectServer } from '../rpc-module-subject-server';\r\nimport { RpcExtensionBrokerRequest, RpcExtensionBrokerRequestKey } from './rpc-extension-broker-model';\r\nimport { RpcExtensionBrokerRequestHandler } from './rpc-extension-broker-request-handler';\r\n\r\n/**\r\n * Rpc extension broker subject interface for module side\r\n */\r\nexport interface RpcExtensionBrokerModuleSubject extends Subject<DeferredData<RpcExtensionBrokerRequest, void>> {}\r\n\r\n/**\r\n * The class to implement Rpc extension with Subject server for module side\r\n */\r\nexport class RpcExtensionBrokerModuleSubjectServer\r\n        extends RpcModuleSubjectServer<RpcExtensionBrokerRequest, void>\r\n        implements RpcExtensionBrokerRequestHandler {\r\n\r\n    /**\r\n     * Initializes a new instance of the RpcExtensionBrokerModuleSubjectServer class.\r\n     */\r\n    constructor(rpc: Rpc) {\r\n        super(rpc, RpcExtensionBrokerRequestKey.command);\r\n    }\r\n\r\n    /**\r\n     * The handler to respond a request for Rpc extension call.\r\n     *\r\n     * @param data The extension object.\r\n     * @returns return the Promise<void> object.\r\n     */\r\n    public handler(data: RpcExtensionBrokerRequest): Promise<void> {\r\n        return this.processNextForSubject(RpcExtensionBrokerRequestKey.command, data);\r\n    }\r\n}\r\n"]}