ByJC

<md-progress-bar mode="indeterminate" color="accent" *ngIf="isDisplay" style="position:fixed"></md-progress-bar>

ByJC

import { Component, OnInit } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { ProgressBarService } from './progressbar.service';

@Component({
  selector: 'app-progressbar',
  templateUrl: './progressbar.component.html',
  styleUrls: ['./progressbar.component.scss'],
  providers:[]
})

ByJC

<div *ngFor="let result of results | async">
    <p>{{result}}</p>
</div>

ByJC

export class FormControlComponent {

  myControl = new FormControl();
  results: Observable<any[]>;

  constructor(public http: Http) {
    this.results = this.myControl.valueChanges
      .startWith('someValue')
      .map(text => new formatQuery(text)) // generate a url
      .switchMap(url => this.http.get(url), (_, res)=> res.json());

ByJC

<input [formControl]="myControl"/>

ByJC

  myControl = new FormControl();

  constructor() {
    this.myControl.valueChanges
      .map(text => console.log(text))
      .subscribe();
  }

ByJC

import { Component, OnInit } from '@angular/core';
import { Http } from '@angular/http';
import { Observable } from 'rxjs/Observable';

import { ExampleService } from './example.service'

import 'rxjs/Rx';
import 'rxjs/add/observable/forkJoin';
import 'rxjs/add/operator/mergeMap';

ByJC

import { Http } from '@angular/http';
import { Injectable } from '@angular/core';

@Injectable ()
export class ExampleService {

    constructor(public http: Http) {}

    getDataA() {
        return this.http.get('http://www.server.com/dataA').map(res => res.json());

ByJC

import { Component, OnInit } from '@angular/core';
import { Http } from '@angular/http';
import { Observable } from 'rxjs/Observable';

import 'rxjs/Rx';
import 'rxjs/add/operator/mergeMap';

@Component({
  selector: 'example-flatMap',
  templateUrl: 'flat-map.component.html'

ByJC

import { Component, OnInit } from '@angular/core';
import { Http } from '@angular/http';
import { Observable } from 'rxjs/Observable';

import 'rxjs/Rx';
import 'rxjs/add/observable/forkJoin';

@Component({
  selector: 'example-fork-join',
  templateUrl: 'fork-join.component.html'