Software: Apache/2.4.41 (Ubuntu). PHP/8.0.30 

uname -a: Linux apirnd 5.4.0-204-generic #224-Ubuntu SMP Thu Dec 5 13:38:28 UTC 2024 x86_64 

uid=33(www-data) gid=33(www-data) groups=33(www-data) 

Safe-mode: OFF (not secure)

/var/www/html/wincloud_gateway/node_modules/zen-observable/test/   drwxr-xr-x
Free 13.08 GB of 57.97 GB (22.57%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     subscribe.js (3.41 KB)      -rw-r--r--

import assert from 'assert';
import { testMethodProperty } from './properties.js';

describe('subscribe', () => {

  it('is a method of Observable.prototype', () => {
    testMethodProperty(Observable.prototype, 'subscribe', {
      configurable: true,
      writable: true,
      length: 1,
    });
  });

  it('accepts an observer argument', () => {
    let observer;
    let nextValue;
    new Observable(x => observer = x).subscribe({
      next(v) { nextValue = v },
    });
    observer.next(1);
    assert.equal(nextValue, 1);
  });

  it('accepts a next function argument', () => {
    let observer;
    let nextValue;
    new Observable(x => observer = x).subscribe(
      v => nextValue = v
    );
    observer.next(1);
    assert.equal(nextValue, 1);
  });

  it('accepts an error function argument', () => {
    let observer;
    let errorValue;
    let error = {};
    new Observable(x => observer = x).subscribe(
      null,
      e => errorValue = e
    );
    observer.error(error);
    assert.equal(errorValue, error);
  });

  it('accepts a complete function argument', () => {
    let observer;
    let completed = false;
    new Observable(x => observer = x).subscribe(
      null,
      null,
      () => completed = true
    );
    observer.complete();
    assert.equal(completed, true);
  });

  it('uses function overload if first argument is null', () => {
    let observer;
    let completed = false;
    new Observable(x => observer = x).subscribe(
      null,
      null,
      () => completed = true
    );
    observer.complete();
    assert.equal(completed, true);
  });

  it('uses function overload if first argument is undefined', () => {
    let observer;
    let completed = false;
    new Observable(x => observer = x).subscribe(
      undefined,
      null,
      () => completed = true
    );
    observer.complete();
    assert.equal(completed, true);
  });

  it('uses function overload if first argument is a primative', () => {
    let observer;
    let completed = false;
    new Observable(x => observer = x).subscribe(
      'abc',
      null,
      () => completed = true
    );
    observer.complete();
    assert.equal(completed, true);
  });

  it('enqueues a job to send error if subscriber throws', async () => {
    let error = {};
    let errorValue = undefined;
    new Observable(() => { throw error }).subscribe({
      error(e) { errorValue = e },
    });
    assert.equal(errorValue, undefined);
    await null;
    assert.equal(errorValue, error);
  });

  it('does not send error if unsubscribed', async () => {
    let error = {};
    let errorValue = undefined;
    let subscription = new Observable(() => { throw error }).subscribe({
      error(e) { errorValue = e },
    });
    subscription.unsubscribe();
    assert.equal(errorValue, undefined);
    await null;
    assert.equal(errorValue, undefined);
  });

  it('accepts a cleanup function from the subscriber function', () => {
    let cleanupCalled = false;
    let subscription = new Observable(() => {
      return () => cleanupCalled = true;
    }).subscribe();
    subscription.unsubscribe();
    assert.equal(cleanupCalled, true);
  });

  it('accepts a subscription object from the subscriber function', () => {
    let cleanupCalled = false;
    let subscription = new Observable(() => {
      return {
        unsubscribe() { cleanupCalled = true },
      };
    }).subscribe();
    subscription.unsubscribe();
    assert.equal(cleanupCalled, true);
  });

});