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

corrected tear down logic handling in observables. Added support for observable query results

cin - - Load All Authors

File last commit:

r110:1a190b3a757d v1.4.0 default


                r110:1a190b3a757d

v1.4.0 default

Download file

             observable-tests.ts
        
                    52 lines
            
             | 1.1 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / djx / src / test / ts / observable-tests.ts
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

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

      import * as t from "tap";

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

          next(1);

          complete();

          next(2);

      });

      const consumer1 = {

          sum: 0,

          next(v: number) {

              this.sum += v;

          }

        cin
    
linting

              r108
            
      };

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

              r102
            
      subj1.subscribe(consumer1);

      t.equal(consumer1.sum, 1, "Should get only one value");

      subj1.subscribe(consumer1);

      t.equal(consumer1.sum, 2, "Should get the value again");

      const consumer2 = {

          value: 0,

          completed: false,

          next(v: number) { this.value = v; },

          complete() { this.completed = true; }

      };

      let maps = 0;

      subj1

          .map(v => {

        cin
    
linting

              r108
            
              t.comment(`map1: ${v * 2}`);

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

              r102
            
              maps++;

              return v * 2;

          })

          .map (v => {

        cin
    
linting

              r108
            
              t.comment(`map2: ${v * 2}`);

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

              r102
            
              maps++;

              return v * 2;

          })

          .map(v => {

        cin
    
linting

              r108
            
              t.comment(`map3: ${v * 2}`);

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

              r102
            
              maps++;

        cin
    
linting

              r108
            
              return v * 2;

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

              r102
            
          })

          .subscribe(consumer2);

      t.equal(consumer2.value, 8, "Should map");

      t.equal(maps, 3, "The map chain should not be executed after completion");

        cin
    
corrected tear down logic handling in observables. Added support for observable query results

              r110
            
      t.ok(consumer2.completed, "The completion signal should pass through");

	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 `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	import { observe } from "./observable";
		import * as t from "tap";

		const subj1 = observe<number>(({ next, complete }) => {
		next(1);
		complete();
		next(2);
		});

		const consumer1 = {
		sum: 0,
		next(v: number) {
		this.sum += v;
		}
cin linting	r108	};
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102
		subj1.subscribe(consumer1);
		t.equal(consumer1.sum, 1, "Should get only one value");

		subj1.subscribe(consumer1);
		t.equal(consumer1.sum, 2, "Should get the value again");

		const consumer2 = {
		value: 0,
		completed: false,
		next(v: number) { this.value = v; },
		complete() { this.completed = true; }
		};

		let maps = 0;

		subj1
		.map(v => {
cin linting	r108	t.comment(`map1: ${v * 2}`);
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	maps++;
		return v * 2;
		})
		.map (v => {
cin linting	r108	t.comment(`map2: ${v * 2}`);
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	maps++;
		return v * 2;
		})
		.map(v => {
cin linting	r108	t.comment(`map3: ${v * 2}`);
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	maps++;
cin linting	r108	return v * 2;
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	})
		.subscribe(consumer2);

		t.equal(consumer2.value, 8, "Should map");
		t.equal(maps, 3, "The map chain should not be executed after completion");
cin corrected tear down logic handling in observables. Added support for observable query results	r110	t.ok(consumer2.completed, "The completion signal should pass through");