Function runFunction

ui/public/lbug_wasm_worker.js:404–437

(jobUID, fn, args)

      }
    }
    function runFunction(jobUID, fn, args) {
      return __awaiter(this, void 0, void 0, function* () {
        let syncResult;
        try {
          syncResult = fn(...args);
        } catch (error) {
          return postJobErrorMessage(jobUID, error);
        }
        const resultType = isObservable(syncResult) ? 'observable' : 'promise';
        postJobStartMessage(jobUID, resultType);
        if (isObservable(syncResult)) {
          const subscription = syncResult.subscribe(
            (value) =>
              postJobResultMessage(jobUID, false, common_1.serialize(value)),
            (error) => {
              postJobErrorMessage(jobUID, common_1.serialize(error));
              activeSubscriptions.delete(jobUID);
            },
            () => {
              postJobResultMessage(jobUID, true);
              activeSubscriptions.delete(jobUID);
            },
          );
          activeSubscriptions.set(jobUID, subscription);
        } else {
          try {
            const result = yield syncResult;
            postJobResultMessage(jobUID, true, common_1.serialize(result));
          } catch (error) {
            postJobErrorMessage(jobUID, common_1.serialize(error));
          }
        }
      });
    }
    function expose2(exposed) {
      if (!implementation_1.default.isWorkerRuntime()) {
        throw Error('expose() called in the master thread.');