reactivex

1열

1답변

저는 Rx.Net을 사용하고 있으며 Observable을 사용하여 시계열 점 (double, timestamp)을 발생시킵니다. 때마다 새로운 점은 내가 지난 30 초 말할 수에서 평균 값을 계산하려는 도착한다. count/timestamp를 기반으로하지 않는 Window/Buffer를 겹쳐 쓰는 것이 필요하다고 생각합니다. 나는 SlidingWindow의

1열

1답변

관찰 가능한 값과 관찰 가능한 값을 쌍으로 매핑하는 방법은 무엇입니까?</p> <p><code>Observable<MainInfo> mainInfoObs</code> 및</p> <p><code>Observable<AdditionalInfo> additionalInfoObs(MainInfo mainInfo)</code> 기능 :

내가이 명 관찰 가능한 있다고 가정하자. additionalInfoObs이 mainInfo에 의존하기 때문에 난, 난 그냥 우편을 사용할 수 없습니다 Pair<MainInfo, AdditionalInfo> 받을 이러한 관찰 가능한을 결합 어떻게 든 할 수 있습니다. 그래서 나는 블록과 중단 mainInfoObs .map(mainInfo->new P

0열

1답변

RxSwift - 버퍼의 시간 범위를 조절하는 방법

기본적으로 행에서 버튼을 몇 번 클릭했는지 계산하는 코드 스 니펫을 다시 만들려고합니다. 코드는 RxJS에 있으며 학습 목적으로 RxSwift로 변환하려고 시도하지만 버퍼 및 스로틀 부분을 파악할 수 없습니다. You can see the js code on jsfiddle 현재 나는이 tapButton.rx.tap .buffer(timeSpan

0열

1답변

zip rxjava 연산자가 메소드를 확인할 수 없습니다. subscribe

네트워크를 통해 여러 요청을 보내고 싶습니다.이 tutorial 이 도움이되었지만 후반부에 머물러 있습니다. 나는 onSubscribe, onNext, ....에서 값 (OrderValues)을 반환 할 것으로 예상됩니다. apply 함수가 값을 반환하기 때문에. 그러나 ...., onNext는 기본적으로 void를 반환합니다. 어떤 도움이 여기에 당신이

4열

3답변

RxJS Observable로 조건이 충족 될 때까지 어떻게 ajax 요청을 반복합니까?

응답이 RxJS를 사용하여 데이터를 가질 때까지 요청을 반복하려고하는데,이 시점에서 성공 (또는 실패) 처리기를 호출하고 싶지만 RxJS가 문제가 있습니다. // ... redux-observable action observable .mergeMap(() => fetchData() .repeatWhen(response => r

1열

1답변

취소 가능한 Observable의 합리적인 구현입니까?

나는 콜백을 취하는 함수와 2 개의 약속을 반환하는 함수라는 다중 단계 프로세스를 가지고 있는데, 취소를 지원하는 Observable을 구축하고 싶습니다. 내가 가진 것은 : let observableFromEvent = evt => Observable.create(({ next, error, complete }) => { let canceled

0열

1답변

ReactiveX로 점진적 이미지 로딩

미리보기 미리보기 이미지를로드하고 이미지를 이미지로로드하려고합니다. 언제든지 이미지가로드되면 미리보기 이미지가 삭제되는지 확인하고 싶습니다. 은하기 실시 예 고려해 서열 1 프리뷰 이미지 서열 2 채용 이미지 요청 인 요청 서열 3 결합 서열을 인 순서 (4)는 생성 된 이미지 렌더링 시퀀스 . Example 1: 1 ------P------- 2 -

0열

1답변

rxpy는 항목을 관찰 할 수있게 넣습니다.

이 질문은 rxpy에 관한 것입니다. 소스에서 관찰 할 수있는 메시지를 처리하는 반응적인 시스템을 구축하려고합니다. 그 외에도, 나는 그것을 사육사를 기반으로 한 리더 선거 시스템과 통합하려고 노력하고있다. 이 조합을 사용하면 프로세스 팜의 한 리더 만 메시지 스트림을 처리 할 수 있습니다. 아래는 내가 작성하려고하는 코드의 요지입니다. # event_

0열

1답변

"결과"는 nativescript/angular의 http.get 요청에서 얻은 Observable의 .map 연산자에서 무엇을 의미합니까

nativescript/angular 튜토리얼을 수행하고 있으며 이해할 수없는 코드에서 뭔가를 발견했습니다 해명을 원한다. import { Injectable } from "@angular/core"; import { Http, Headers } from "@angular/http"; import { Observable } from "rxjs/Rx";

0열

1답변

RxSwift - X 초 동안 항목을받지 못하고 내 보낸 후

나는 이러한 동작을 구현하는 방법을 찾아 내려고 노력했지만 제대로 된 해결책을 찾을 수 없었습니다. 나는 무엇을 달성하고자하는 var dataSource = Variable<[T]>([]) var arrayObserver: Observable<SomeType> { return dataSource.asObservable() .map(