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

added observable subject producer

cin - - Load All Authors

File last commit:

r125:cede47727a1b v1.7.0 default


                r125:cede47727a1b

v1.7.0 default

Download file

             subject-tests.ts
        
                    77 lines
            
             | 1.5 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / djx / src / test / ts / subject-tests.ts
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      import { observe, subject } from "./observable";

      import * as tap from "tap";

      tap.test("Subject tests", t => {

          let nextEvent: (value: string) => void = () => void (0);

          const subj1 = observe(subject<string>(({ next }) => {

              t.comment("Start subject");

              nextEvent = next;

              return () => {

                  nextEvent = () => void (0);

                  t.comment("Stop subject");

              };

          }));

          const h1 = subj1.subscribe({

              next: v => t.comment(`h1 next: ${v}`)

          });

          nextEvent("first");

          const h2 = subj1.subscribe({

              next: v => t.comment(`h2 next: ${v}`)

          });

          nextEvent("second");

          h1.unsubscribe();

          nextEvent("third");

          h2.unsubscribe();

          t.pass("Subject finished");

          t.end();

      }).catch(e => console.error(e));

      tap.test("Subject tests #2", t => {

          let nextEvent: (value: string) => void = () => void (0);

          const subj1 = observe(subject<string>(({ next, complete }) => {

              t.comment("Start subject");

              complete();

              nextEvent = next;

              return () => {

                  nextEvent = () => void (0);

                  t.comment("Stop subject");

              };

          }));

          const h1 = subj1.subscribe({

              next: v => t.comment(`h1 next: ${v}`)

          });

          nextEvent("first");

          const h2 = subj1.subscribe({

              next: v => t.comment(`h2 next: ${v}`)

          });

          nextEvent("second");

          h1.unsubscribe();

          nextEvent("third");

          h2.unsubscribe();

          t.pass("Subject finished");

          t.end();

      }).catch(e => console.error(e));

	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, subject } from "./observable";
				import * as tap from "tap";

				tap.test("Subject tests", t => {

				let nextEvent: (value: string) => void = () => void (0);

				const subj1 = observe(subject<string>(({ next }) => {
				t.comment("Start subject");

				nextEvent = next;

				return () => {
				nextEvent = () => void (0);
				t.comment("Stop subject");
				};
				}));

				const h1 = subj1.subscribe({
				next: v => t.comment(`h1 next: ${v}`)
				});

				nextEvent("first");

				const h2 = subj1.subscribe({
				next: v => t.comment(`h2 next: ${v}`)
				});

				nextEvent("second");

				h1.unsubscribe();

				nextEvent("third");

				h2.unsubscribe();

				t.pass("Subject finished");
				t.end();
				}).catch(e => console.error(e));


				tap.test("Subject tests #2", t => {

				let nextEvent: (value: string) => void = () => void (0);

				const subj1 = observe(subject<string>(({ next, complete }) => {
				t.comment("Start subject");

				complete();
				nextEvent = next;

				return () => {
				nextEvent = () => void (0);
				t.comment("Stop subject");
				};
				}));

				const h1 = subj1.subscribe({
				next: v => t.comment(`h1 next: ${v}`)
				});

				nextEvent("first");

				const h2 = subj1.subscribe({
				next: v => t.comment(`h2 next: ${v}`)
				});

				nextEvent("second");

				h1.unsubscribe();

				nextEvent("third");

				h2.unsubscribe();

				t.pass("Subject finished");
				t.end();
				}).catch(e => console.error(e));