reactivex

0열

1답변

게으른 초기화 된 필드에서 관찰 가능

이 클래스가 있습니다. 이 클래스의 클라이언트는 chatHub 콜백에 할당 된 즉시 chatHub 필드의 인스턴스를 가져옵니다. connection.connected (() -> chatHub = connection.createHubProxy ("ChatHub"))); chatHub이 null 일 수 있습니다. 우리는 chatHub을 초기화하자마자 가입자를

rx-java observable lazy-initialization reactivex 2016-08-31

---

2열

2답변

RxJava가 onNext를 무시합니다.

나는 Retrofit에서 URL을 부르고 있는데, 그 결과는 신경 쓰지 않습니다. 어쨌든 onNext 메서드를 무시할 수 있습니까? 현재 내가 사용 : getRetrofit().create(UserAPI.class) .doSomething(a, b) .subscribeOn(Schedulers.newThread()) .s

java rx-java reactive-programming rx-android reactivex 2016-09-02

---

1열

1답변

결과에 페이지 매김을하기 위해 Reactive Extensions에서 두 개의 관찰 가능 항목을 결합하는 방법은 무엇입니까?

RxSwift를 사용하는 iOS 앱에서 페이지 매김 시스템을 개발하려고합니다. 유스 케이스는 간단합니다 : 사용자는 검색 필드에 텍스트를 입력 할 수 있으며 앱은 페이지가 매겨진 요청을 수행합니다. 사용자가 값을 변경하면 첫 번째 페이지에서 새로운 요청이 수행됩니다 (즉, 관찰 가능 값을 1로 재설정해야 함). 사용자가 검색 필드를 지우거나 2 자 미만의

swift reactive-programming observable rx-swift reactivex 2016-09-02

---

0열

1답변

Observable.defer()에 의해 생성 된 Observable에 대한 retry()가 새로운 Observable?

private Observable<String> serverResponsesStream() { return Observable.defer(() -> Observable.combineLatest( ComSocketFactory.createObservable(), // generates new Observable<ComSocket> inst

java rx-java reactivex 2016-09-03

---

1열

1답변

Rxswift + Moya + Moya-ObjectMapper 오류 처리

네트워크 요청을하기 위해 Rxswift에서 Moya과 Moya-ObjectMapper을 사용 중입니다. 내 네트워크 요청은 다음과 같습니다. let provider = RxMoyaProvider<APIClient>() requestHospitalButton.rx_tap .withLatestFrom(hospitalCode) .flatMa

swift rx-swift reactivex moya 2016-09-05

---

2열

2답변

RxSwift로 주기적으로 업데이트

다음 설정을 사용하여 API에서 개체 (예 : GitHub 문제)를 검색합니다. 이것은 잘 작동합니다. let provider: RxMoyaProvider<GitHub> let issues: Driver<[IssueViewModel]> init(provider: RxMoyaProvider<GitHub>) { self.provider = pro

ios swift rx-swift reactivex moya 2016-09-06

---

0열

1답변

`ReplaySubject`가 가입시 클로저를 실행하게 할 수 있습니까?

실제 구독이있을 때만 값 비싼 작업을 시작하기 시작할 콜드 관찰 가능을 만들고 싶습니다. ReplaySubject은 실제 가입이 이루어 졌을 때 값 비싼 백그라운드 작업을 시작할 수 있고 관찰 가능 항목을 만들지 않아도되는 부분을 제외하고는 적당합니다. 그렇게 할 방법이 있습니까? 어떤 종류의 onSubscribed { ... } 방법입니다. let obs

swift rx-swift reactivex 2016-09-08

---

1열

1답변

RxSwift에서> 연산자는 무엇을 의미하며 어디에서 문서화됩니까?

RxSwift와 관련된 다양한 코드 조각 (예 : https://github.com/ReactiveX/RxSwift/issues/35)에서 >- 연산자를 보았지만 이에 대한 문서를 찾을 수 없습니다. 무슨 뜻이에요? 여기서 예이다 : combineLatest(emailIsValid, passwordIsValid) >- and >- sign

ios swift reactive-programming rx-swift reactivex 2016-09-13

---

3열

2답변

Angular2에서 RxJs 5를 사용하는 REST 클라이언트에 대한 시간 기반 캐시

ReactiveX/RxJs를 처음 사용하고 RxJ를 사용하여 원활하게 실행 가능한지 궁금합니다. 기본 제공 연산자를 조합하는 것이 좋습니다. 다음은 내가 달성하기를 원하는 것입니다 : 저는 REST API와 통신하는 Angular2 어플리케이션이 있습니다. 응용 프로그램의 다른 부분은 서로 다른 시간에 동일한 정보에 액세스해야합니다. 같은 요청을 반복해서

caching angular rxjs rxjs5 reactivex 2016-09-14

---

2열

1답변

subscribeOn()에 Subject를 사용하는 경우

Subject에서 subscribeOn()을 호출했을 때 어떤 결과가 발생했는지 궁금합니다. 기본적으로 이것은 방출되는 스레드 항목을 변경하지 않는다는 것을 이해합니다. 다른 부정적인 부작용을 유발할 수 있는지 궁금합니다. 일반적으로 subscribe()를 다른 스레드에서 동일한 Observable로 호출하는 것이 안전하지 않습니까? 그렇다면 subscri

rx-java reactivex 2016-09-14

---