implab/implabjs-djx Files · djx/src/test/ts/state-tests.ts

bump dependencies, bump ts to 5.2...

bump dependencies, bump ts to 5.2 moved observables logic to ObservableImpl fixed while/until bug with complete handler multiple call

cin - - Load All Authors

File last commit:

r133:a3fba6b6c42e default


                r155:6acbe6efbe20

v1.10.2 default

Download file

             state-tests.ts
        
                    28 lines
            
             | 599 B
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / djx / src / test / ts / state-tests.ts
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      import { observe } from "./observable";

      import { buffer } from "./operators/buffer";

      import * as t from "tap";

      interface CounterState {

          count: number;

          label: "low" | "mid" | "high"

      }

      let set: (v: CounterState) => void = () => void (0);

      const initial: CounterState = { count: 0, label: "low" };

      let value = initial;

      const obs = observe<CounterState>(({ next }) => {

          next(initial);

          set = next;

      }).pipe(buffer(2));

      set({ count: 10, label: "mid" });

      obs.subscribe({

          next: v => value = v

      });

      t.equal(value.count, 10, "State should update");

      set({ count: 20, label: "high" });

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				import { observe } from "./observable";
				import { buffer } from "./operators/buffer";
				import * as t from "tap";

				interface CounterState {
				count: number;

				label: "low" \| "mid" \| "high"
				}

				let set: (v: CounterState) => void = () => void (0);
				const initial: CounterState = { count: 0, label: "low" };
				let value = initial;

				const obs = observe<CounterState>(({ next }) => {
				next(initial);
				set = next;
				}).pipe(buffer(2));

				set({ count: 10, label: "mid" });

				obs.subscribe({
				next: v => value = v
				});

				t.equal(value.count, 10, "State should update");

				set({ count: 20, label: "high" });