All files wait.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
/**
 * Copyright (c) OpenLens Authors. All rights reserved.
 * Licensed under MIT License. See LICENSE in root directory for more information.
 */
import type { IComputedValue } from "mobx";
import { runInAction, when } from "mobx";
import type { Disposer } from "./disposer";

export async function waitUntilDefined<T>(getter: (() => T | null | undefined) | IComputedValue<T | null | undefined>, opts?: { timeout?: number }): Promise<T> {
  return new Promise<T>((resolve, reject) => {
    when(
      () => {
        const res = typeof getter === "function"
          ? getter()
          : getter.get();
        const isDefined = res != null;

        if (isDefined) {
          resolve(res);
        }

        return isDefined;
      },
      () => {},
      {
        onError: reject,
        ...(opts ?? {}),
      },
    );
  });
}

export function onceDefined<T>(getter: () => T | null | undefined, action: (val: T) => void): Disposer {
  let res: T | null | undefined;

  return when(
    () => {
      res = getter();

      if (res != null) {
        const r = res;

        runInAction(() => {
          action(r);
        });

        return true;
      }

      return false;
    },
    () => {},
  );
}