rxjs

    1熱度

    2回答

    我發誓,RxJS將會是我的死亡。我很確定這是一個實際的錯誤,無論是RxJS,Typescript還是Angular的實現。這適用於the RxJS docs page(該網頁上的JavaScript控制檯可以作爲一個RxJS沙箱): new Rx.Observable(observer => observer.next([{ id: 0, name: 'John Doe'

    0熱度

    1回答

    我試圖觸發流的一個變化後的動作: import {Observable} from 'rxjs/Observable'; import 'rxjs/add/operator/startWith'; const from$: Observable<number> = this.form.controls['input1'].valueChanges; const to$: Observabl

    0熱度

    1回答

    我想應用Angular Material Text Filtering的示例使用來自http get調用的數據。 export class MyDtoDataSource extends DataSource<IMyDto> { private _filterChange = new BehaviorSubject(''); public get filter(): str

    1熱度

    2回答

    比方說,我有一個像下面這樣的組件單元測試: @Component({ selector: 'example', template: ` ` }) export class ExampleComponent { value: any; @Output() output: EventEmitter<any> = new EventEmitter();

    1熱度

    2回答

    我試圖建立與rxjs一個angular2部件 this._subscription = Observable.timer(1000).subscribe(() => { console.log('inside timeout') }) 內可觀察到的超時功能,在其他方法退訂它。但是如果我改變 let _subscription = Observable.timer(10

    2熱度

    1回答

    我有一個數據流,具有快速傳入的數據。我想通過保持順序將它們插入到數據庫中。我有一個數據庫,它返回一個承諾,在插入成功時解決。 我想創建一個Rx流,緩衝新數據,直到緩衝數據被插入。 我該怎麼做?

    0熱度

    4回答

    我想獲得服務輸入的最大長度(通過http調用獲取值)。 有沒有辦法通過只調用一次服務來做到這一點? <input type="text" [attr.maxLength]="getMaxLength()/> 感謝

    1熱度

    1回答

    我已經開始使用React中的redux-observable,並且因間隔API請求而停滯不前。 這對我的史詩,它的工作原理很好的代碼,但只有一個請求: const fetchPointValue = (action$) => action$ .ofType(actionTypes.REQUEST_POINT_VALUE) .mergeMap(action

    2熱度

    2回答

    我有一個函數,有時返回一個值包裝在一個可觀察的和其他時間返回一個普通的值。有沒有一種優雅的方式來獲得價值?目前我正在使用這種策略: let mayBeAnObservable = getData(); let resultObservable = mayBeAnObservable instanceof Observable ? mayBeAnObservable : Observable.of

    3熱度

    1回答

    我有一個服務this.service.getAllItems()返回一個可觀察到的項目的陣列的:Observable<ITEM[]> 一地圖這樣的結果對每個項目發佈到RESTAPI: this.service.getAllItems() .map(items => ...for each item of items, call this.apiService.postMessage(item).