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

Added tag v1.8.0 for changeset

cin - - Load All Authors

File last commit:

r125:cede47727a1b v1.7.0 default


                r130:5811271fa858

default

Download file

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

        cin
    
added observable subject producer

              r125
            
      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

cin added observable subject producer	r125	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));