observable

    0热度

    1回答

    我有两个观测 const refreshClick$ = Observable.fromEvent(this.btn, 'click').startWith('click') const interval$ = Observable.interval(5000, 5000) this.subscription = interval$ .merge(refreshClick$)

    -2热度

    1回答

    RxJava Kotlin平面图不会从分割字符串中返回分离对象。而是返回列表 val source: Observable<String> = Observable.just("521934/2342/FOXTROT") .flatMap{Observable.fromArray(it.split("/"))} .subscribe{Log.d(TAG, "$it")} 它返回列表: [5

    0热度

    2回答

    使用* A视图列表中的条目ngFor基于可观察到: view.html <ion-searchbar [(ngModel)]="filter" (ionInput)="filterMeds()"></ion-searchbar> <ion-list> <ion-item *ngFor="let medicine of getMeds$() | async"> {{medic

    -1热度

    1回答

    我有可观察到的返回如下的方法: fun currentLocation(): Observable<LatLngFix> { if (GoogleApiAvailability.getInstance().isGooglePlayServicesAvailable(context) != ConnectionResult.SUCCESS || !context.isLoca

    0热度

    1回答

    我有一个问题,我相信是由于我在ngrx-store中的初始状态的组合,并试图从observable得到初始响应。我使用的数据表,以及大量的静态报表的数据 - 所以我只是想从第一个“真正”的回应: Observable.zip(this.sites$, this.devices$, this.machines$, this.machineContent$) 在我NGRX减速我定义为初始状态[]为每个

    1热度

    1回答

    我试图创建一个处理技术错误,但我面临的问题的服务。 类型返回的项目变更的,如果我做的一个问题: Observable.of(1, 2, 3).subscribe( item => {}, // item type is number error => {} ); Observable.of(1, 2, 3).catch(error => { // do somet

    0热度

    1回答

    我有一个Angular 2/4服务,它使用observables与其他组件进行通信。 服务: let EVENTS = [ { event: 'foo', timestamp: 1512205360 }, { event: 'bar', timestamp: 1511208360 } ]; @In

    0热度

    1回答

    我试图使用Observable来监视元素的clientX。 这样的: `const wrap = document.getElementById('wrap'); const body = document.body; const mouseDown = Observable.fromEvent(wrap, 'mousedown'); const mouseUp = Observable.

    1热度

    2回答

    我正在处理某些正在记录来自队列的数据。将队列处理成Observable非常容易,以便我的代码中可以有多个端点接收队列中的信息。 此外,我可以确定信息按顺序到达。这个位很好地工作,因为Observables确保这一点。 但是,一个棘手的问题是,我不希望观察者在下一件事完成处理之前得到通知。但Observer完成的处理是异步的。 作为一个更具体的例子,可能很简单。想象一下我的队列包含URL。我在我的代

    0热度

    1回答

    考虑以下两个变量: let int = Variable<Int>(1) let string = Variable<String>("hey!") 我们假设他们都绑定到其他UI已经,如: int.asObservable.bind(to:variable1) string.asObservable.bind(to:variable2) 我怎样才能确保int.asObservable