TypeScript observable.Observable类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› TypeScript›TypeScript教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了TypeScript中rxjs/internal/observable.Observable类的典型用法代码示例。如果您正苦于以下问题：TypeScript Observable类的具体用法？TypeScript Observable怎么用？TypeScript Observable使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了Observable类的4个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1: findLocationId

    findLocationId(city: string): Observable<City[]> {
        const uri = 'https://api.buienradar.nl/data/search/1.0/?query=' + city + '&country=BE&locale=nl-BE';
        const result$: Observable<AxiosResponse> = this.httpService.get(uri);

        return Observable.create((obs) => {
            const cities: City[] = [];
            result$.subscribe((data: AxiosResponse) => {
                    const dataIndex: number = data.data.length > 1 ? (data.data.length - 1) : 0;
                    if (data.data.length > 0) {
                        for (const singleCity of data.data[dataIndex].results) {
                            const uriPieces: string[] = singleCity.uri.split('/');
                            cities.push(new City(Number(uriPieces[uriPieces.length - 1]), singleCity.main, singleCity.sub));
                        }
                    }
                }, (error) => {
                    console.log(error);
                },
                () => {
                    obs.next(cities);
                    obs.complete();
                });
        });
    }

开发者ID:beele，项目名称:WeatherGenieV2-Backend，代码行数:23，代码来源:buienradar.service.ts

示例2: City

 return Observable.create((obs) => {
     const cities: City[] = [];
     result$.subscribe((data: AxiosResponse) => {
             const dataIndex: number = data.data.length > 1 ? (data.data.length - 1) : 0;
             if (data.data.length > 0) {
                 for (const singleCity of data.data[dataIndex].results) {
                     const uriPieces: string[] = singleCity.uri.split('/');
                     cities.push(new City(Number(uriPieces[uriPieces.length - 1]), singleCity.main, singleCity.sub));
                 }
             }
         }, (error) => {
             console.log(error);
         },
         () => {
             obs.next(cities);
             obs.complete();
         });
 });

开发者ID:beele，项目名称:WeatherGenieV2-Backend，代码行数:18，代码来源:buienradar.service.ts

示例3: subscribe

 return RxJS.Observable.create(function subscribe(obs) {
     input.subscribe(val => obs.next(val * 10),
         err => obs.error(err),
         () => obs.complete()
     );
 });

开发者ID:MarcoLeko，项目名称:async-patterns，代码行数:6，代码来源:introduction.ts

示例4: setTimeout

import {Observable} from 'rxjs/internal/Observable';
import {filter, map, publish, reduce, shareReplay} from 'rxjs/operators';
import {Observer} from 'rxjs/internal/types';
import {ConnectableObservable} from 'rxjs/internal/observable/ConnectableObservable';

const observer: Observer<number> = {
    next: x => console.log('Value: ', x),
    error: err => console.error('Error occurred: ', err),
    complete: () => console.log('Done!')
};

const alias: Observable<number> = RxJS.Observable.create((obs) => {
    obs.next(1);
    obs.next(2);
    obs.next(3);
    setTimeout(() => {
        obs.next(4);
        obs.complete();
    }, 1000);
});

console.log('Before subscribe');
alias.subscribe(observer);
console.log('After subscribe');


/*** unicast vs multicast **/
const randomNumber = new Observable<number>(obs => {
    obs.next(Math.random());
});

开发者ID:MarcoLeko，项目名称:async-patterns，代码行数:30，代码来源:introduction.ts

注：本文中的rxjs/internal/observable.Observable类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。