rxjs非同步程式設計

2021-09-24 01:31:44 字數 1819 閱讀 4444

import  from '@angular/core';

import from 'rxjs';

@injectable()

export class requestservice

//同步

getdata()

getcallbackdata(cb), 1000);

} getpromisedata(), 3000); })}

getrxjsdata(), 3000);

})} //多次執行rxjs

getpromiseintervaldata(), 1000); })}

getrxjsintervaldata(), 1000); })}

getrxjsintervalnum(), 1000); })}

}

import  from '@angular/core';

import from '../../services/request.service';

import from 'rxjs/operators';

@component()

export class homecomponent implements oninit

ngoninit() );

//3、promise獲取非同步資料

var promisedata=this.request.getpromisedata();

promisedata.then((data)=>)

//4、rxjs獲取非同步方法裡面的資料

// var rxjsdata=this.request.getrxjsdata();

// rxjsdata.subscribe((data)=>)

//5、過一秒以後撤回剛才的操作

var streem=this.request.getrxjsdata();

var d=streem.subscribe((data)=>)

settimeout(()=>,1000)

//6、promise 執行多次(沒有這個能力)

var intervaldata=this.request.getpromiseintervaldata();

intervaldata.then((data)=>)

//7、rxjs執行多次

// var streeminterval=this.request.getrxjsintervaldata();

// streeminterval.subscribe((data)=>)

//8、用工具方法對返回的資料進行處理

/*var streemnum=this.request.getrxjsintervalnum();

streemnum.pipe(

filter((value)=>

}))

.subscribe((data)=>)

*//*

var streemnum=this.request.getrxjsintervalnum();

streemnum.pipe(

map((value)=>)

)

.subscribe((data)=>)

*/var streemnum=this.request.getrxjsintervalnum();

streemnum.pipe(

filter((value)=>

}),map((value)=>)

)

.subscribe((data)=>)

}}

angular7 Rxjs 非同步請求

promise 的建立之後,動作是無法撤回的。observable 不一樣,動作可以通過 unsbscribe 方 法中途撤回,而且 observable 在內部做了智慧型的處理。promise 建立之後動作無法撤回 let promise new promise resolve 2000 prom...

RxJS 學習之旅 實現簡易RxJS

本片文章主要通過實現rxjs一些簡單操作符,來進一步了解rxjs 本系列文章 你應該了解的函式實現與組合應用 初識rxjs與搭建倉庫 rxjs基礎概念與使用 操作符篇 簡易實現observable 本篇文章可以學到什麼?深入了解observablejs 基礎知識 類 原型 observable 即r...

rxjs入門4之rxjs模式設計

觀察者模式其實在日常編碼中經常遇到,比如dom的事件監聽,如下 function clickhandler event document.body.addeventlistener click clickhandler 簡而言之 觀察者模式就如同上 有乙個事件源 dom 的click事件 也就是ab...