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

added observable subject producer

cin - - Load All Authors

File last commit:

r116:aac297dda27d v1.6.0 default


                r125:cede47727a1b

v1.7.0 default

Download file

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

        cin
    
added reduce() and next() methods to observable...

              r116
            
      import { empty, observe } from "./observable";

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

              r102
            
      import * as t from "tap";

        cin
    
added reduce() and next() methods to observable...

              r116
            
      import { Cancellation } from "@implab/core-amd/Cancellation";

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

              r102
            
      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;

          })

        cin
    
added pipe method to observable

              r114
            
          .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");

        cin
    
added pipe method to observable

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

          [1, 2, 3, 4, 5].forEach(next);

          complete();

        cin
    
added reduce() and next() methods to observable...

              r116
            
          return () => {

              t.comment("subj2: unsubscribe");

          };

      });

      const consumer3 = {

          even: 0,

          odd: 0,

          completed: false,

          subscribed: 0,

          unsubscribed: 0,

          next(v: "even" | "odd") {

              this[v] ++;

          },

          complete() {

              this.completed = true;

          },

          subscribe() {

              this.subscribed++;

          },

          unsubscribe() {

              this.unsubscribed++;

          }

      };

      const subj3 = subj2.pipe<"even" | "odd">(self => ({ next, complete, error }) => {

          consumer3.subscribe();

          let count = 0;

        cin
    
added pipe method to observable

              r114
            
          const h = self.subscribe({

              next: val => {

                  if (val % 2 === 0)

                      next("odd");

                  else

                      next("even");

        cin
    
added reduce() and next() methods to observable...

              r116
            
                  if (++count === 4)

                      complete();

        cin
    
added pipe method to observable

              r114
            
              },

              complete,

              error

          });

          return () =>{

        cin
    
added reduce() and next() methods to observable...

              r116
            
              consumer3.unsubscribe();

        cin
    
added pipe method to observable

              r114
            
              h.unsubscribe();

          };

      });

        cin
    
added reduce() and next() methods to observable...

              r116
            
      subj3.subscribe(consumer3);

      t.equal(consumer3.odd, 2, "Should get 2 odd elements");

      t.equal(consumer3.even, 2, "Should get 2 even elements");

      t.ok(consumer3.completed, "The sequence should completed");

      t.equal(consumer3.subscribed, 1, "The subscription should be done once");

      t.equal(consumer3.unsubscribed, 1, "The cleanup should be done after completion");

      subj2.reduce((a,b) => a + b).subscribe({

          next: val => t.comment("subj2: reduce =", val),

        cin
    
added pipe method to observable

              r114
            
          complete: () => t.comment("subj2: complete")

      });

        cin
    
added reduce() and next() methods to observable...

              r116
            
      subj2.reduce((a,b) => a + b).next()

          .then(value => t.comment("subj2: next reduce=", value))

          .catch(() => {});

      subj2.next().then(val => t.equal(val, 1, "Should peek the first element")).catch(() => {});

      const cancelled = new Cancellation(cancel => cancel());

      t.rejects(subj2.next(cancelled), "Cancelled next() method should fail").catch(() => {});

      t.rejects(empty.next(), "Empty sequence should fail to get next element").catch(() => {});

	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 reduce() and next() methods to observable...	r116	import { empty, observe } from "./observable";
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	import * as t from "tap";
cin added reduce() and next() methods to observable...	r116	import { Cancellation } from "@implab/core-amd/Cancellation";
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102
		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;
		})
cin added pipe method to observable	r114	.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");
cin added pipe method to observable	r114
		const subj2 = observe<number>(({ next, complete }) => {
		[1, 2, 3, 4, 5].forEach(next);
		complete();
cin added reduce() and next() methods to observable...	r116	return () => {
		t.comment("subj2: unsubscribe");
		};
		});

		const consumer3 = {
		even: 0,
		odd: 0,
		completed: false,
		subscribed: 0,
		unsubscribed: 0,
		next(v: "even" \| "odd") {
		this[v] ++;
		},
		complete() {
		this.completed = true;
		},
		subscribe() {
		this.subscribed++;
		},
		unsubscribe() {
		this.unsubscribed++;
		}
		};


		const subj3 = subj2.pipe<"even" \| "odd">(self => ({ next, complete, error }) => {
		consumer3.subscribe();
		let count = 0;
cin added pipe method to observable	r114	const h = self.subscribe({
		next: val => {
		if (val % 2 === 0)
		next("odd");
		else
		next("even");
cin added reduce() and next() methods to observable...	r116	if (++count === 4)
		complete();
cin added pipe method to observable	r114	},
		complete,
		error
		});
		return () =>{
cin added reduce() and next() methods to observable...	r116	consumer3.unsubscribe();
cin added pipe method to observable	r114	h.unsubscribe();
		};
		});

cin added reduce() and next() methods to observable...	r116	subj3.subscribe(consumer3);

		t.equal(consumer3.odd, 2, "Should get 2 odd elements");
		t.equal(consumer3.even, 2, "Should get 2 even elements");
		t.ok(consumer3.completed, "The sequence should completed");
		t.equal(consumer3.subscribed, 1, "The subscription should be done once");
		t.equal(consumer3.unsubscribed, 1, "The cleanup should be done after completion");

		subj2.reduce((a,b) => a + b).subscribe({
		next: val => t.comment("subj2: reduce =", val),
cin added pipe method to observable	r114	complete: () => t.comment("subj2: complete")
		});
cin added reduce() and next() methods to observable...	r116
		subj2.reduce((a,b) => a + b).next()
		.then(value => t.comment("subj2: next reduce=", value))
		.catch(() => {});

		subj2.next().then(val => t.equal(val, 1, "Should peek the first element")).catch(() => {});

		const cancelled = new Cancellation(cancel => cancel());
		t.rejects(subj2.next(cancelled), "Cancelled next() method should fail").catch(() => {});

		t.rejects(empty.next(), "Empty sequence should fail to get next element").catch(() => {});