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).