reactivex

6열

1답변

IronPython 스크립트 내부에서 lambdas를 사용하여 Rx 확장 메서드를 호출 할 수 있습니까?

누군가 정말이 이상한 관찰을 설명해 주시겠습니까? IronPython 내부에서 Rx 확장 메서드를 호출하려고했지만 단순히 불가능한 것으로 판명되었습니다. 나는이 간단한 예제로 그것을 끓여 냈다 : import clr clr.AddReference("System.Core") from System.Linq import Enumerable def proc

1열

1답변

Observable.defer의 Observer 's onNext met을 호출하십시오.

저는 새로운 반응 형 프로그래머입니다. 옵저버의 onNext 메소드를 호출하고 싶었습니다. 거기에 좋은 방법이 있습니까? 당신은 단지 하나의 가입자에서 onNext 호출 할 수 있기 때문에 예 - Observable.create(new Observable.OnSubscribe<Integer>() { @Override public void

0열

2답변

RxJava : subscribeOn 및 observeOn이 예상대로 작동하지 않습니다.

어쩌면 저는 단지 subscribeOn 및 observeOn의 내부 동작을 이해하고 있을지 모르지만 최근에 정말 이상한 것이 있습니다. 나는 subscribeOn이 처음에 처리를 시작하는 곳을 스케줄러로 결정했다. (특히 map이 데이터 스트림을 변경하는 경우) observeOn은 maps 사이의 어느 곳에서든지 스케줄러를 변경할 때 사용할 수있다. 적절한

2열

1답변

조건부 Observable.forkJoin() building

함수의 매개 변수에 따라 forkJoin() 메서드를 작성하려고합니다. 예를 들어 : 매개가 하늘의 경우 => 매개가 비어있는 경우 forkJoin() 안에 그것을 위해 HTTP 요청을 넣지 마십시오 => HTTP 요청을 넣지 마십시오 forkJoin() 안에 그것을 에 대한 코드 : getAllByIds(parameter1: any, parameter2:

2열

1답변

이벤트를 ReactiveX Observable에 넣는 방법?

I는 어떤 종래의 이벤트 발행에 의해 호출되는 이벤트 콜백 방법 public void onSomethingHappened(Information info) { 있다. 이제 이것을 ReactiveX로 랩핑하고자합니다. 어떻게 하시겠습니까? 내가 PublishSubject<T> 클래스를 발견하고 안드로이드 API에서 LocationListener을 포장하기

0열

2답변

가입 기간 중에 예외가 발생하면 어떻게해야합니까?

"제 3 자"게시자를 RxJava로 랩핑하려고합니다. 구독하는 동안 게시자를 준비 중이며 예외가 발생할 수 있습니다 (게시자를 사용할 수없는 경우). 예외가 발생하면 어떻게해야합니까? 1) subscribe 메소드에서 던집니까? 2) 옵서버의 OnError 방법으로 밀어 넣으시겠습니까? 3) 다른 것? OnError으로 푸시하는 방법에 대해 생각해 봤습니다

2열

1답변

누가 ReactiveX에서 링크를 보유하고 있습니까?

Java의 PropertyChangeSupport에서 observable은 옵저버 목록을 유지 관리합니다. 따라서 observable이 삭제되면 observer는 가비지 수집 대상이됩니다. 그래서 관측 가능 링크가 있습니다. 나는 이것이 ReactiveX에 해당하지 않는다는 인상을 가지고 있습니다. observable에는 subscribe 메서드가 있지만

2열

1답변

takewhile을 사용하여 마지막 요소를 내보내는 방법?

요소 이후에 항목을 방출하는 스트림이 있습니다. 나는 어떤 요소가 있는지 압니다. 해당 요소가 방출되면 스트림은 더 방출되지 않습니다. 문제는 onComplete를 방출하지 않는다는 것입니다. takeWhile처럼 더 적은 것을 필요로하지만 마지막 요소도 emmiting합니다. (ReactiveX TakeWhile에서 추출 된 원본 이미지) 나는이 작업을

0열

1답변

변경 감지 각도 2 모델의 속성

내 모델 propery이 변경되면 매번 JQuery 함수를 호출해야합니다. 예를 들어 person = {firstName:firstName, lastName:lastName} 내가 사람 개체의 firstName을 속성을 변경 한 경우, 때마다 나는 함수를 실행해야합니다. 사실이 객체의 속성을 구독하는 것과 같은 것이 필요합니다. 어떻게 가능합니까? 미리

0열

1답변

RxSwift + MVVM : 노출 드라이버/관찰 가능한 속성에 효율적인 방법으로지도 들어오는 모델

내가 RxSwift 뷰 모델과 뷰를 결합하기 위해 사용하고, 나는 내보기 모델의 속성을 노출 약 10 드라이버가 있습니다 let title: Driver<String> let description: Driver<String> let price: Driver<String> ... 을 들어오는 일련의 모델에서 관측 대상을 유도하는 가장 좋은 방법은 무