ArtemRomanovsky

emitValue(observer) {  
    let i = 0;
       const id = setInterval(() => {
           observer.next(i++)
       }, 1000)
       return () => { clearInterval(id) }
   } 

   createObservable(emitValueFn) {
       return {

ArtemRomanovsky

const observable = Rx.Observable.interval(1000).take(5);  
    const observerA = {...};
    const observerB = {...};

    const hybrid = {
      observers: [],
      subscribe: (obs) => {
        this.observers.push(obs);
      }
      next: (v) => {

ArtemRomanovsky

const observable = Rx.Observable.interval(1000).take(5);  
    const observerA = {...};
    const observerB = {...};

    const subject = new Rx.Subject();

    observable.subscribe(subject);

    subject.subscribe(observerA); // first execution
    setTimeout(() => {

ArtemRomanovsky

const connectableObservable = Rx.Observable  
      .interval(1000)
      .take(5)
      .multicast(new Rx.Subject());
    const observerA = {...};
    const observerB = {...};

    connectableObservable.connect();

    connectableObservable.subscribe(observerA); // first execution

ArtemRomanovsky

const observable = Rx.Observable  
      .interval(1000)
      .take(5)
      .multicast(new Rx.Subject())
      .refCount();

ArtemRomanovsky

const observable = Rx.Observable  
      .interval(1000)
      .take(3)
      .publish()
      .refCount()

    const observerA = {
      next: (x) =>  console.log('A next ' + x) ,
      complete: () => console.log('A done')
    };

ArtemRomanovsky

const observable = Rx.Observable  
.interval (1000)
.take (3)
.share ()

const observable = Rx.Observable  
      .interval(1000)
      .take(3)
      .share()

ArtemRomanovsky

@Component({  
 template: 
  `<span>I am {{name}}</span>
`,
})
export class MyComponent {    
  name = 'Angular';
}

ArtemRomanovsky

// simplified component factory
function View_MyComponent_0(l) {  
  return jit_viewDef1(0,
    // view defenition nodes
    [
      jit_elementDef2(0, null, null, 1, "span", ...),
      jit_textDef3(null, ["I am ", ...])
    ]
  );
}

ArtemRomanovsky

export interface ViewDefinition {  
  ...
}