reactive-programming

0열

3답변

알 수없는 병렬 하위 작업 수를 하나의 완료 가능으로 합치십시오.

동시 네트워크 요청을 만들어야합니다. 이러한 요청의 결과에 따라 더 많은 요청이 시작될 수 있습니다. 모든 요청이 완료되고 더 이상의 요청을 만들지 않으면 완료되는 하나의 완료 가능을 얻고 싶습니다. 내 질문은 , 다음 코드를 사용하여 달성이 가능하다 :이 예에서 return Completable.defer(() -> { startRequests

java android rx-java reactive-programming 2017-02-28

---

0열

1답변

관찰 가능한 지원 리액턴트 풀

저는 꽤 기본적인 질문이라고 생각하며 잠시 고생했습니다. 저는 Flowable이 있는데, 이는 네트워크에서 항목 묶음을 검색하여 방출합니다. Flowable .create(new FlowableOnSubscribe<Item>() { @Override public void subscribe(FlowableEmitter<Item>

rx-java reactive-programming rx-java2 backpressure 2017-02-28

---

1열

1답변

Java 8을 사용하는 Akka Essentials : 첫 번째 예제의 결과 반환

Akka Essentials Book의 예제를 사용하여 Akka로 첫 반응 형 응용 프로그램을 작성했지만 Result 개체를 인쇄하려면 빈 값 '{}'을 표시하십시오. 결과는 '{galaxia, lejana, mucho, tiempo, vivia, guerrero, esperada, encontrarse}'이어야합니다. 이 예제는 원래 akka 2.0.3에

java akka reactive-programming 2017-02-28

---

18열

1답변

Observer와 Observable를 대체하는 Flow API가 있습니다.

Java 9에서 은 Observer과 Observable을 대체합니까? 그렇지 않다면, 무엇을합니까?

reactive-programming observer-pattern java-9 2017-03-01

---

1열

1답변

Kotlin에서 스프링 웹 플럭스 (반응성) 기능 경로가 예상대로 작동하지 않습니다.

안녕하세요 Kotlin에서 스프링 응용 프로그램을 작성하는 데 관심이있는 좋은 사람들입니다. 스프링 부트 2.0.0 스냅 샷과 spring-webflux으로 놀고 있습니다. 이 코드 조각 : ➜ ~ curl -i http://localhost:8080/1/hello HTTP/1.1 404 Not Found content-length: 0 근무의 경우

spring kotlin reactive-programming spring-webflux 2017-03-02

---

1열

1답변

vertx에서 상용구 코드의 양을 줄이는 방법

vertx.io에 대한 자습서를 여러 개 읽었지만 반복 코드를 최소화하는 방법을 여전히 이해할 수 없습니다. 예를 들어 DB에서 데이터를 가져 오는 RESTful 서비스를 구현해야합니다. AdministratorService.java : public void getAll(RoutingContext routingContext) { jdbc.getCo

java reactive-programming vert.x event-driven 2017-03-02

---

1열

1답변

각각을 관찰 할 수있는 것으로 바꾸십시오.

두리스트가 있습니다 : List<Foo> 및 List<Bar>입니다. List<Foo>의 각 항목에 대해 List<Bar>의 모든 항목을 확인하고 일치하는 값을 설정해야합니다. 오늘은이 코드를 사용하고 있습니다 : fooList.forEach { foo -> barList.forEach { bar -> if(foo.id == bar.id

java rx-java kotlin reactive-programming 2017-03-02

---

1열

1답변

잡히지 않은 ReferenceError : 요구가 정의되지 않았습니다. 응답

CMS에서 프로젝트를 진행 중이며 서버에 액세스 할 수 없습니다. 그래서 4 개 파일을 browser.min.js jquery.min.js react.js react-dom.js remarkable.min.js 와 HTML 페이지에로드 아래 다운로드. 가져 오기를 사용하기 전에 모든 것이 잘 작동합니다. import { sample } from './sam

reactjs reactive-programming 2017-03-03

---

0열

1답변

오류 : (9, 0) 인수 [(io.reactivex : rxandroid : 1.2.1)

에 대한 컴파일 방법을 찾지 못했습니다. 내 안드로이드 스튜디오 프로젝트를 동기화 할 때 오류 : [: rxandroid : io.reactivex 1.2.1] 인수 방법 컴파일() 타입의 객체는 내 build.gradle 파일 이하 org.gradle.api.internal.artifacts.dsl.dependencies.DefaultDependencyH

android reactive-programming 2017-03-04

---

0열

1답변

감기에 걸린 대상을 방송하는 방법 : 역 압력으로 다시 재생 하시겠습니까?

실제로 Scala를 사용하고 있지만 질문은 모든 Rx 및 스트리밍 프레임 워크에 일반적입니다. 내 유스 케이스는 생성 된 관찰 가능 (따라서 콜드)이며 다중 소비자가 정확히 동일한 값을 병렬로 소비하기를 원하지만, 상당히 다른 처리량을 기대합니다. 내가 관찰 할 수있는 것은 재생 가능으로 방송 할 수 있지만 최대 버퍼 크기로 재생하는 일반적인 정책은 오버플

scala reactive-programming akka-stream rx-java2 monix 2017-03-05

---