system.reactive

0열

2답변

수신 예약/차단 문제 : 구독 한 OnNext가 타이머 시퀀스에서 실행되지 않음이 호출되었습니다.

나는 이것에 완전히 혼란스러워합니다. 단지 며칠 동안 Rx에서 일해 왔고, 어딘가에 나의 이해에 근본적인 예외가 있다는 것이 확실합니다. 그래서 다양한 기사를 토대로 수많은 아이디어를 시도한 후에, 제가보기에는 그것을 눈여겨볼 전문가의 눈이 필요합니다. 폴링 메커니즘을 시뮬레이트 한 코드를 테스트하려고합니다. 나는 매우 유용한 참 ... 빨리 오랜 기간 동

system.reactive 2016-11-02

---

0열

1답변

EventStream 및 EventBus

이 EventBus와 EventStream 사이에 어떤 차이가 나 두 단지 동의어가 있는지 궁금 해서요의 차이점은 무엇입니까? 이벤트를 필터링, 변환 등 할 수있는 EventBus 위에있는 EventStream입니까?

c# events system.reactive event-bus 2016-11-10

---

0열

1답변

StartWith와 같은 확장이 있습니까? 그러나 관찰 가능한 시퀀스의 끝 부분에 있습니까?

관찰 가능한 순서에 추가 "닫는 중"항목을 추가하고 싶습니다. 관찰 가능한 시퀀스의 끝 부분에 대해 StartWith과 같은 Reactive LINQ 확장이 있습니까? public static IObservable<TSource> EndWith<TSource>(this IObservable<TSource> source, TSource element) {

c# system.reactive rx.net 2016-11-12

---

2열

1답변

RX : 피사체의 refcount는이

0 내가 다음과 같이 간단한 클래스가 도달 할 때 처리를 수행 internal class DataProvider : IDataProvider { private readonly Subject<string> _dataChangeSubject = new System.Reactive.Subjects.Subject<string>(); privat

c# .net system.reactive reactive-programming 2016-11-15

---

2열

2답변

캐시가 업데이트시 새로운 값을 "DistinctLatest"로 지정하고 구독시 전체 캐시 내용을

다음과 같이 ReplaySubject을 사용하여 캐시를 구현하려고하지만 Rx를 사용하여 문제를 해결할 수 없습니다. 코드 및 동반 테스트를 참조하십시오. 문제는 캐시가 최신 항목을 삭제하고 가장 오래된 항목을 보존한다는 것입니다. public static class RxExtensions { /// <summary> /// A cache

c# .net system.reactive 2016-11-15

---

0열

1답변

어셈블리가 매니페스트와 일치하지 않습니다

Reactiveui (7.0) 및 간단한 인젝터를 사용하는 프로젝트가 있습니다. Reactiveui는 System.Reactive.Linq v2.2.5.0을 사용합니다. NET 4.5.1을 사용하는 프로젝트에서 System.Reacive v3.0.0을 참조하고 있습니다. 나는 재 처리 할 수의 App.config에 다음을 추가 : <dependentAsse

c# manifest system.reactive 2016-11-15

---

0열

1답변

Rx에서 DistinctLatest (및 캐싱) 연산자를 구현하는 방법은 무엇입니까?

나는 커뮤니티에서 잘 처리 한 질문이 A cache serving updates and new values as “DistinctLatest” and full cache contents upon subscription입니다. 위의 질문에서 정의 된 값을 캐싱하고 대체하는 실제 목표는 .DistinctLatest 연산자로 정의 할 수 있다는 질문이 제기되었습

c# .net system.reactive reactive-programming 2016-11-16

---

2열

1답변

Observable.Retry가 메시지를 기록합니까?</p> <pre><code>var obs = Observable .Defer(() => Observable.FromAsync(asyncFunc)) .Retry() </code></pre> <p>그것은 작동하지만 난 때 순서 재시도 알고 싶습니다, 그래서 나는 이러한 상황이 발생 때마다 <code>Logger.Log("Retrying...")</code>를 호출하고 싶습니다 :

나는이 관찰 가능한 있습니다. 어떻게하면됩니까?

c# .net system.reactive observable 2016-11-16

---

2열

1답변

Rx.net - 동기식 대 비동기식 관찰자 - 원본에 의존?

나는 Rx에 매우 익숙하며 내 머리를 감싸고있다. 전반적으로 많이 읽지는 ​​않았지만 실험실에서 먼저 손을 뻗어 보려고했습니다. class Program { static void Main(string[] args) { // one source, produces values with delays IObservable<

c# asynchronous system.reactive 2016-11-17

---

2열

1답변

Reactive Extensions를 사용하여 어떤 조건이 충족되거나 시간 초과가 발생할 때까지 차단되는 관찰 가능 개체의 가입자를 만들 수 있습니까?

여기에 반응 확장을 사용할 수 있습니까? 기본적으로 ESB를 사용하여 메시지 (본질적으로 내 열성적인 관측 대상이 꼭대기에 위치)를 모니터링하고 특정 스레드 (예 : 사용자)가 생성 될 때만 생성되는 스레드에서 차단/일시 중지 할 가입자를 만들고 싶습니다. 조건이 충족되거나 시간 초과가 발생합니다. 내가 Tasks/TaskCompletionSource 및

c# task-parallel-library task system.reactive 2016-11-22

---