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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
import { Accessor, createEffect, createRoot, createSignal, getOwner, onCleanup, Setter, Signal, untrack } from "./signal.js";
// Note: This will add Symbol.observable globally for all TypeScript users,// however, we are not polyfilling Symbol.observable. Ensuring the type for// this global symbol is present is necessary for `observable()` to be// properly typed for 3rd party library's like RXJS.declare global {  interface SymbolConstructor {    readonly observable: symbol;  }}
export type ObservableObserver<T> =  | ((v: T) => void)  | {    next?: (v: T) => void;    error?: (v: any) => void;    complete?: (v: boolean) => void;  };/** * creates a simple observable from a signal's accessor to be used with the `from` operator of observable libraries like e.g. rxjs * ```typescript * import { from } from "rxjs"; * const [s, set] = createSignal(0); * const obsv$ = from(observable(s)); * obsv$.subscribe((v) => console.log(v)); * ``` * description https://www.solidjs.com/docs/latest/api#observable */export function observable<T>(input: Accessor<T>) {  return {    subscribe(observer: ObservableObserver<T>) {      if (!(observer instanceof Object) || observer == null) {        throw new TypeError("Expected the observer to be an object.");      }
      const handler = typeof observer === 'function'        ? observer        : observer.next && observer.next.bind(observer);
      if (!handler) {        return { unsubscribe() { } };      }
      const dispose = createRoot((disposer) => {        createEffect(() => {          const v = input();          untrack(() => handler(v));        });
        return disposer;      })
      if (getOwner()) onCleanup(dispose);
      return {        unsubscribe() {          dispose();        }      };    },    // Here we're intentionally using `Symbol.observable || "@@observable"` directly    // without assigning it to an intermediary variable (e.g. we aren't doing    // `const $$observable = Symbol.observable || "@@observable"`).    // See for more info: https://github.com/solidjs/solid/pull/1118    [Symbol.observable || "@@observable"]() {      return this;    }  };}
export function from<T>(producer: ((setter: Setter<T | undefined>) => () => void) | {  subscribe: (fn: (v: T) => void) => (() => void) | { unsubscribe: () => void };}): Accessor<T | undefined> {  const [s, set] = createSignal<T | undefined>(undefined, { equals: false });  if ("subscribe" in producer) {    const unsub = producer.subscribe((v) => set(() => v));    onCleanup(() => "unsubscribe" in unsub ? unsub.unsubscribe() : unsub())  } else {    const clean = producer(set);    onCleanup(clean);  }  return s;}