reactive-programming

2열

1답변

Project Reactor : 각 요소의 방출을 지연시키는 방법은 무엇입니까?

는 다음 Flux Flux.range(1, 5) .parallel(10) .runOn(Schedulers.parallel()) .map(i -> "https://www.google.com") .flatMap(uri -> Mono.fromCallable(new HttpGetTask(httpClient, uri))) Ht

java reactive-programming project-reactor 2017-05-10

---

0열

1답변

select onchange event.value is undefined

내 구성 요소에서 선택 값이 변경된 후 몇 가지 작업을 수행하려고합니다. 선택 : <select value={current} onChange={this.onSelectChange.bind(this)}> {options} </select> onchange를 이벤트 : onSelectChange(event) { const { cookie

javascript reactjs reactive-programming 2017-05-12

---

1열

1답변

RX Observable을 동적으로 업데이트하는 방법은 무엇입니까? (RxKotlin 및 RxJava에서 작업하지만, 간단하게하기 위해 메타 코드를 사용하여)</p> <p>많은 <code>Reactive Extensions</code> 가이드를

이미 사용 가능한 데이터에서 Observable를 작성하여 시작합니다. The introduction to Reactive Programming you've been missing로부터, 지금 outStream 산출 간단한 필터를 고려 채워진 목록 val list = listOf(1,2,3,4,5) list.toObservable() 에서, RxKo

java rx-java reactive-programming rx-kotlin 2017-05-12

---

2열

1답변

RxSwift의 속도 제한

HTTP 클라이언트에서 속도 제한을 구현하는 현명한 방법을 찾고 있습니다. API의 속도 제한이 모든 리소스에서 초당 5 회의 요청이라고 가정 해 보겠습니다. 현재 구현은 다음과 비슷합니다 final class HTTPClient: HTTPClientProtocol { func getUser() -> Observable<User> {

swift reactive-programming rx-swift 2017-05-14

---

1열

1답변

rxjs에서 스로틀 값을 얻는 방법은 무엇입니까? rxjs 사이트 스로틀 예의

, 방출 된 시퀀스는 0 4 2 1 3 출력 시퀀스는 0 1 var Rx = require('rxjs/Rx'); var times = [ { value: 0, time: 100 }, { value: 1, time: 600 }, { value: 2, time: 400 }, { value: 3, time: 900 },

javascript rxjs reactive-programming throttle 2017-05-16

---

1열

1답변

RxJava2 - 제 소자

임 RxJava2 public static void main(String args[]) { Observable.concat(getFromMemory(), getFromFileCache(), getFromNetwork()) .firstElement() .subscribe((integer) -> {

reactive-programming rx-java2 2017-05-16

---

0열

3답변

안드로이드 프로젝트에서 리 액티브 프로그래밍으로 Junit하기

나는 RxAndroid/RxJava를 사용하는 안드로이드 프로젝트에서 JUnit4를 사용하려고합니다. 나는 개조 호출 (지금은 하나에 불과)에 대한 UUIDApi.java 단지 인터페이스 public interface UUIDApi { static final String BASE_URL = "https://www.uuidgenerator.net"

java android rx-java junit4 reactive-programming 2017-05-22

---

0열

1답변

rxjs Observable.catch() 작동하지 않음

내 응용 프로그램을 죽이는 예외가 발생하여 catch()/consume 할 수 없습니다. 나는 이것에 아주 새롭다 그래서 나는 아마 catch를 가진 무언가를 잘못하고있다? private callConfigService(): Observable<Map<string,string>> { try { let confObs = this.cont

angular rxjs reactive-programming rxjs5 2017-05-22

---

2열

1답변

가능한 한 빨리 요청과 출력 결과를 결합하십시오.

짧은 버전 : Akavache를 추가하지 않은 상태에서처럼 내 코드 (https://github.com/akavache/Akavache/blob/501b397d8c071366c3b6783aae3e98695b3d7442/src/Akavache/Portable/JsonSerializationMixin.cs#L202)에 Akavache와 같은 GetAndFetc

c# system.reactive reactive-programming 2017-05-23

---

1열

2답변

반응적 디자인 : 던지기 vs. 게시 오류

다음 코드 예에는 (Rx) Swift 냄새가 있지만 반응 형 기능 및 던지기 기능이있는 언어는 일반적인 질문입니다. 관찰 가능한 시퀀스를 반환하지만 시퀀스를 생성하기 전에 몇 가지 온 전성 검사를 수행하는 기능을 고려하십시오. 점검 실패는시 v 스가 값을} 성할 수 없음을의 L합니다. 상태 유효성 검사 실패의 경우 함수가 한 번만 관찰 할 수 있으면 오류가

swift try-catch reactive-programming rx-swift 2017-05-23

---