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

Added tag v1.9.0 for changeset

cin - - Load All Authors

File last commit:

r133:a3fba6b6c42e default


                r147:ae34865a484b

default

Download file

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

        cin
    
added 'buffer' and 'subject' observable operators

              r133
            
      import { observe } from "./observable";

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

        cin
    
added observable subject producer

              r125
            
      import * as tap from "tap";

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

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

        cin
    
added 'buffer' and 'subject' observable operators

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

        cin
    
added observable subject producer

              r125
            
              t.comment("Start subject");

              nextEvent = next;

              return () => {

                  nextEvent = () => void (0);

                  t.comment("Stop subject");

              };

        cin
    
added 'buffer' and 'subject' observable operators

              r133
            
          }).pipe(subject);

        cin
    
added observable subject producer

              r125
            
          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);

        cin
    
added 'buffer' and 'subject' observable operators

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

        cin
    
added observable subject producer

              r125
            
              t.comment("Start subject");

              complete();

              nextEvent = next;

              return () => {

                  nextEvent = () => void (0);

                  t.comment("Stop subject");

              };

        cin
    
added 'buffer' and 'subject' observable operators

              r133
            
          }).pipe(subject);

        cin
    
added observable subject producer

              r125
            
          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 'buffer' and 'subject' observable operators	r133	import { observe } from "./observable";
		import { subject } from "./operators/subject";
cin added observable subject producer	r125	import * as tap from "tap";

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

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

cin added 'buffer' and 'subject' observable operators	r133	const subj1 = observe<string>(({ next }) => {
cin added observable subject producer	r125	t.comment("Start subject");

		nextEvent = next;

		return () => {
		nextEvent = () => void (0);
		t.comment("Stop subject");
		};
cin added 'buffer' and 'subject' observable operators	r133	}).pipe(subject);
cin added observable subject producer	r125
		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);

cin added 'buffer' and 'subject' observable operators	r133	const subj1 = observe<string>(({ next, complete }) => {
cin added observable subject producer	r125	t.comment("Start subject");

		complete();
		nextEvent = next;

		return () => {
		nextEvent = () => void (0);
		t.comment("Stop subject");
		};
cin added 'buffer' and 'subject' observable operators	r133	}).pipe(subject);
cin added observable subject producer	r125
		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));