reactive-programming

2열

1답변

PublishSubject - onComplete() 후에도 살아남 으십시오.

현재 내가 직면 한 두 가지 문제점이 있습니다. 1) RetrofitProvider.getInstance().getCurrentWeather(.....) 라인이 호출되면 네트워크 호출이 완료됩니다. 관찰자가 연결될 때까지 어떻게 지연 될 수 있습니다. 2) 일단 weatherInfoPublisher.onComplete()이 호출되면 다음에이 객체에서 onC

1열

1답변

무한 스트림의 시작/종료 이벤트를 서로 연관시키는 방법은 무엇입니까?

rabbitMQ의 이벤트 스트림이 Event: {id, type, timestamp} 인 것처럼 보입니다. 값은 다음과 같습니다 id : (A) rrive/(d)는 나는 내가이 출발 이벤트에 이벤트 도착 일치하는 이벤트의 새로운 스트림을 (생성 할 epart : type 몇 가지 고유 한 문자열 연속). id | type | time 1 | a | 0

0열

1답변

RX.net의 DropQueue 메커니즘

나는 RX.net을 사용하여 문제가 발생했다. 해결책을 찾지 못했다. 나는 관찰 가능한 실시간 로그 메시지를 가지고있다. 나는 그들이이 와이어를 통해 전송되기 전에 logObservable에서 실시간 로그 메시지를 직렬화는 TCP 인터페이스를 통해 노출 할 var logObservable = /* Observable stream of log messages

0열

1답변

각각의 출력이 다음의 입력 일 때 관찰 가능 배열

RxSwift를 사용하여 여러 데이터 소스에서 작업을 실행하려고합니다. 그러나, 나는 다음과 같은 것을 성취 할 방법을 모른다. 나는 각각의 출력이 다음의 입력이어야하는 관측의 배열을 가지고있다. 그래서, 나는 첫 번째 관찰 할 수있는 것을 얻고, 결과를 기다리고 그것을 다음에 전달하고, 배열의 끝까지 가져 와서 하나의 최종 값을 반환하고 싶습니다. 그럴

0열

1답변

RxSwift는 - 가입자

에서 emited 이벤트를 필터링 flatMapFirst을 방지하기 위해 어떻게 코드를 더 적게 같은 있습니다 let requestResult = someSubject .flatMapFirst{ [weak self] _ -> Observable<ResponseClass> in return self?.triggerNetworkRequest

0열

1답변

다중 호출을 피하는 공통 관찰 가능을 만듭니다.

메시지를 읽거나 쓰는 방법이 있습니다. fun sendMessage(message: String): Observable<MESSAGE> { return readMessage().doOnSubscribe { socket.write(message) } } readMessage()는 스트림 (socket.read())에서 뜨

1열

1답변

반응성 엔드 포인트 디자인

Im Learning WebFlux. 위키 반응성 프로그램 인 것을 말한다 명령형 프로그래밍 환경에서, 예를 들어 , A : = B + C을 가에 B + C 결과가 할당되는 것을 의미 인스턴트 표현식을 평가 한 후에, B 및/또는 C 값은 와의 값에 영향 변경 될 수 없다. 그러나 반응성 프로그래밍, 의 값은 자동으로 업데이트가있을 때마다 B 및/또는 C

1열

1답변

차단 작업에 Mono <Object> .publishOn (Schedulers.elastic)을 사용할 수 있습니까? 반응 스트림에서 작업을 차단 사용할 때

나는 우리가 내 게시자가 항목의 목록을 발행 할 때 말이 이해 Publisher<Object>.publishOn(Schedulers.elastic).subscribe(//blocking operations go here) 사용해야 이해 (예를 들어 : 플럭스) 미래 항목은 현재까지 기다릴 필요가 없습니다 차단 작업으로 인해 항목이 차단되었습니다. 그러나 M

0열

1답변

RxSwift/Moya - 기능을 통해 반환 된 경우 시퀀스가 시작되지 않습니다.

Moya를 통해 네트워크 요청을 시작하려고합니다. let provider = MoyaProvider<User>() provider.rx.request(.Auth(username: username, password: password)) .filterSuccessfulStatusAndRedirectCodes() .debug()

3열

1답변

lettable 연산자 및 관찰 가능한 생성 방법 가져 오기

Angular 5 및 RxJS 5.5.2로 업그레이드하고 Observable.of 연산자를 가져 오려고합니다. lettable 사업자하기 전에, 우리는 이런 식으로했다 : add를 포함하는 경로에서 import 'rxjs/add/observable/of'; // Usage Observable.of(...) 하지만 지금은 수입이 좋습니다. letta