system.reactive

2열

1답변

rx의 라이브 카운트 방출 요소

RxAndroid에서 스트림에서 이미 처리 된 요소의 양을 계산할 방법이 있습니까? 은 그 같은 데 : Observable.fromArray(new String[]{"these", "are", "my", "values", "."}) .map(s -> doSomeCoolStuff(s)) // ... .subscribe(a

rx-java system.reactive reactive-programming rx-android 2017-03-18

---

2열

2답변

Rx.Net을 사용하여 조건부 샘플 결합기를 작성하는 방법

관찰 할 수있는 샘플을 만들고 싶지만 모든 조건을 받아들이고 싶은 특정 조건이있는 상황이 있습니다. 이것은 내 시도이지만 주 시퀀스에 대한 지속적인 재 등록으로 인해 안전하지 않다고 느낍니다. 예를 들어, 샘플링이 계속 켜지고 꺼지는 경우 메인 시퀀스가 ​​항상 가입시 값을 생성하면 항상 중복 이벤트가 발생합니다. IObservable<T> SampleM

c# system.reactive 2017-03-20

---

0열

1답변

는 관찰 가능한 및 약속

나는 목록이 검색되면, 각 항목 갈 필요 항목의 배열의 관찰 가능한을 반환하는 방법 getList()이있는 서비스, MyService, getList(): Observable<Item[]> 같은 뭔가를 결합 MyService, fillItem(Item)의 두 번째 방법을 통해. fillItem(item: Item) { BackEnd.retrie

rx-java rxjs system.reactive reactive-programming 2017-03-20

---

0열

1답변

Observable에서 observable 하위 항목이 x 개 이상인 항목을 필터링하는 방법

IObservable 하위 속성이있는 IObservable 개체가있는 경우 하위 관찰 지점을 필터링하여 하위 속성이 X 번호 이상인 인스턴스 만 포함하려면 어떻게해야합니까? 항목 중. 예를 들어 다음 테스트 케이스에는 2 개의 MyClass가 포함 된 IObservable이 있습니다. 첫 번째에는 5 개의 정수와 2의 관찰 가능 항목이 포함되어 있습니다.

c# system.reactive rx.net 2017-03-20

---

0열

2답변

RX 제목, 조건이 충족 될 때까지 그룹화/연결

항목 스트림이 있고 조건이 충족 될 때까지 속성별로 그룹화하는 구독을 만들고 싶습니다. 예를 들어 Id이 나타날 때까지 EventItem을 이름으로 그룹화한다고 가정 해 봅시다. 요점은 더 이상 관련 이벤트가 없다는 것을 알리는 특정 Id을 볼 때까지 이벤트를 상관시키는 것입니다. 그런 다음 상호 연관된 이벤트의 각 그룹에 대해 몇 가지 작업을 수행하려고합

c# system.reactive 2017-03-22

---

0열

1답변

Rx.NET에서 LinqPad 오류가 관찰되었습니다

LinqPad에서 Rx.NET을 실행하려고합니다. 그림에서 보는 것처럼 Rx.NET DLL을 추가했습니다. 제가 보는 오류가 는 CS0103 이름 '관찰 가능한'는 현재 컨텍스트에 존재하지 않는 것입니다. 어떻게이 오류를 해결할 수 있습니까?

system.reactive linqpad 2017-03-25

---

1열

1답변

타임 스탬프를 기반으로 ReactiveX로 이동 평균을 구현합니다.

저는 Rx.Net을 사용하고 있으며 Observable을 사용하여 시계열 점 (double, timestamp)을 발생시킵니다. 때마다 새로운 점은 내가 지난 30 초 말할 수에서 평균 값을 계산하려는 도착한다. count/timestamp를 기반으로하지 않는 Window/Buffer를 겹쳐 쓰는 것이 필요하다고 생각합니다. 나는 SlidingWindow의

c# system.reactive reactivex 2017-03-27

---

0열

1답변

async/await, RX 및 LINQ를 사용한 비동기 메시지 처리

소켓 프로토콜 구현을 단순화하기 위해 Reactive Extensions를 async/await과 함께 사용하고 있습니다. 특정 메시지가 도착할 때 (예 : 각 '핑'메시지에 'pong'보내기) 수행해야하는 작업이 있으며 특정 응답을 비동기 적으로 기다려야하는 방법도 있습니다. private Subject<string> MessageReceived = ne

c# .net linq async-await system.reactive 2017-03-28

---

0열

1답변

방출 값 특정 조건이 충족되는 경우에만 다른 내가 가진 뷰 모델이

다른 vlaue을 방출 다음 : 내가하고 싶은 무엇 enum Detection {NotTriggered, Triggered}; public Detection AlertState => _alertState.Value; public DateTimeOffset? LastAlertTime => _lastAlertTime.Value; 다른 속성 : 이 있으며 기본값

system.reactive reactiveui 2017-04-03

---

3열

2답변

IObservable.Subscribe (IObserver <T>) 과부하 란 무엇입니까? 내가 <code>.Subscribe</code> 표현을 쓰고 있어요 때

나는 종종 ReSharper에서이 버전 = 4.0.0.0을 mscorlib에에있는 나에게 다음과 같은 과부하를 선택한 것을 발견이 걸릴 대부분의 과부하는 매우 다른 것 같다 namespace System { public interface IObservable<out T> { IDisposable Subscribe(IObserve

.net system.reactive 2017-04-07

---