reactive-programming

2열

2답변

모든 방출 된 스트림을 집계하여 rxJava로 내부적으로 방출하십시오.

데이터 페이지 A, B, C, D...을 방출하는 스트림이 있습니다. 어떤 연산자를 사용하면 다음과 같은 스트림을 얻을 수 있습니까? [A], [A, B], [A, B, C], [A, B, C, D]...? 나는 collect 또는 toList을 알고 있지만 스트림 끝에서만 한 번만 출력됩니다.

java rx-java reactive-programming reactivex 2016-11-22

---

1열

3답변

하나의 관측 값을 다른 관측 값으로 필터링하는 방법은 무엇입니까?

https://github.com/neuecc/UniRx와 , 가 나는 A가 B에 Sample에 의해 필터링 할 두 개의 관찰 가능한 A를 가지고 B. 내가 원하는 것 같아하지만 그것의 부정적인. A.filterBy(B) .Subscribe(x => Debug.Log(x)); //executed only when B is not streaming (갱

unity3d reactive-programming reactive 2016-11-22

---

0열

1답변

Vertx 스레딩 모델

Vertx 스레딩 모델과 관련된 두 가지 질문이 있습니다. The documentation는 언급 : (N 기본적으로 핵심이 어디 * 2) Vert.x 인스턴스는 N 이벤트 루프 스레드를 유지 기본적으로. 많은 현대 애플리케이션에서 요구되는 동시성의 수준 , 차단 방법은 단지 확장되지 않습니다 Vertx 또한 이벤트 처리에 대한 오랜 기간을 필요로하는 서버

java reactive-programming vert.x 2016-11-22

---

0열

2답변

Observable next operator usage confusion

나는 angularfire 인증을 위해 codebase을 사용했지만이 코드의 작동 방식을 이해할 수 없었습니다. 기본적으로 나는 observer.next()이 어떤 맥락에서 사용되고 있는지 혼란 스럽다. 나는이 방법이 관찰 할 수있는 것을 돌려 주어야한다고 이해하지만, 어떻게하면 .next()이 도움이되는지 이해한다. 또한 takelast의 별칭은 next

angular reactive-programming angularfire observable angularfire2 2016-11-23

---

1열

3답변

RxAndroid에서 구독자를 중지하는 방법?

나는 피 감시 다음과 같이 작성합니다 public Observable<FileObjectModel> getAllFiles() { return Observable.create(new Observable.OnSubscribe<FileObjectModel>() { @Override public void call(Subscriber<

rx-java reactive-programming rx-android 2016-11-24

---

2열

1답변

RxJS 응답 결과 배열을 제한하고 반환하는 가장 좋은 방법

일부 데이터를 얻기 위해 Angular 2의 HTTP 서비스를 사용하고 있으며, API는 'n'개의 결과를 반환하지만 'x'값만 처리하려고합니다. API 끝점에 액세스 할 수 없다는 것을 고려하면 (제한 또는 findOne 종류의 메소드를 생성하기 위해) API에 반환 될 결과의 수를 처리하는 가장 좋은 방법을 시도하고 있습니다. 내 HomeService의

arrays http angular rxjs reactive-programming 2016-11-24

---

7열

1답변

동적 인 ggplot 레이어가 nearPoints()로 반짝임

나는 근본적인 것에 익숙하지만 여기에서 뭔가 어려움을 겪고 있습니다. 그 지점을 강조 표시하기 위해 점을 클릭하면 ggplot 레이어를 추가하고 싶습니다. 나는 이것이 ggvis에서 가능하다는 것을 알고 있으며 갤러리에 좋은 예가 있지만 nearPoints()을 사용하여 클릭을 UI 입력으로 캡처 할 수 있기를 바랍니다. 나는 ggplot 레이어와 별도로

r ggplot2 shiny reactive-programming shinyapps 2016-11-25

---

1열

1답변

반응 상태 객체 배열을 업데이트하는 방법

새 사용자 객체를 허용하기 위해 상태 내부의 사용자 배열을 업데이트하는 방법을 알아야합니다. 상태 사용자 배열에는 ID와 이름 만 포함됩니다. 업데이트 추가 기능을 사용하여 사용자 배열에서 항목을 푸시하려고합니다. var newUser = {id:1, name:'Foo'}; let newState = update(this.state, {users: {$p

reactjs reactive-programming 2016-11-26

---

1열

1답변

concat : 독립적 인 특정 다음 함수로 각 구독을 처리하는 방법

각각의 응답을 독립적으로 관찰 할 수있는 concat에서 구독을 처리하고 싶습니다. angular2에서 Rxjs 5를 사용하고 있습니다. let source1 = //some Http service let source2 = //some Http service let source3 = //some Http service Observable.concat

javascript asynchronous rxjs reactive-programming rxjs5 2016-11-27

---

2열

1답변

RxJava를 사용하여 병렬 작업 목록의 결과를 하나의 HashMap에 결합하십시오.

List<Task>입니다. Task은 Map<String, JsonElement>을 반환하는 단일 메소드 인터페이스입니다. List<Task>을 병렬로 실행하고 각각 Task의 결합 된 결과로 새로운 HashMap을 반환하려면 어떻게해야합니까? 나는 현재이 있습니다 List<Task> tasks = getTasks(); Observable.from(ta

java rx-java reactive-programming rx-android 2016-11-27

---