Method Initialize

backend/Src/StreamDispatcher.ts:10–27

()

    }

    public Initialize() {
        this.observables.forEach(x => {
            const plugin = this.GetActivePlugin(x.url);

            // Unknown url or no available plugin
            if (plugin === null) {
                return;
            }

            const linkedObservable = this.pluginStreams.get(plugin.id);

            if (linkedObservable === undefined) {
                throw new Error(`Missing linked plugin '${plugin.name}' for '${x.url}'`);
            }

            linkedObservable.add(x.url);
        });
    }

    public AddPlugin(plugin: number, observables: Set<string>) {
        this.pluginStreams.set(plugin, observables);