system.reactive

1열

1답변

Rx를 사용하여 부울 상태에 가입

나는 IObservable<bool>을 가지고 있으며 마지막 n 항목이 true로 설정되면 알림을 받고 싶습니다. 같은 것을 내가 노력하고있어 것들에 대한 : MyBool.Buffer(10).SelectMany(x => x).All(x => x).Subscribe(x => /*do something*/); 그러나 그것은 한 번만 발사; 그것은 어떻게 든

c# system.reactive 2017-02-27

---

0열

2답변

IObservable을 생성자에 전달 - 좋습니다.

는 내가 강하게 방법에 매개 변수로 IObservable<T>을 가지고 있지 제안했다 IObservable을 사용하는 방법에 대한이 웹 사이트에 comment .. 일반적인 규칙 (가이드 라인)으로 를 참조하십시오. 해당 메소드가 새로운 Rx 연산자 인 경우 명백한주의 사항입니다. Select, MySpecialBuffer, Debounce 등 그래서이 조

system.reactive 2017-03-03

---

0열

1답변

ReactiveX에서 두 개의 부울 관측 값을 병합하는 방법

최근 Rx에서 작업 중이며 두 관측 가능 항목을 병합하고 명령을 작성하는 데 문제가 있습니다. 나는 두 개의 관찰 대상을 가지고 있으므로, 그 대상에서 명령을 내리고 싶습니다. 그러면 해당 관찰 대상이 참인 경우에만 명령을 실행할 수 있습니다. 여기에 내 코드 :이 BuyCommand = playerData.Gold.Select(x => x >= boost

c# unity3d system.reactive 2017-03-05

---

1열

1답변

Rx

이있는 각 이벤트에 대해 지연된 두 번째 후속 이벤트 생성 현재 반응 형 프레임 워크로 MIDI 메시지를 처리하려고합니다. NoteOn 이벤트를 생성 할 때는 NoteOff 이벤트를 따라야합니다. 그렇다면 일정 시간이 지났을 때 각 노트 다음에 두 번째 이벤트를 보내는 가장 좋은 방법은 무엇일까요? 뭔가 같은 : NoteOn 및 NoteOff 메시지가 동일

c# .net linq system.reactive 2017-03-06

---

1열

1답변

다음 onComplete 전에 전화하는 것을 피하는 방법은 끝났습니까?

일괄 적으로 데이터 일괄 처리를 가져오고 그 청크를 구독자에게 가져 오는 데이터 서비스 클래스가 있다고 가정 해 보겠습니다. public class DataService { public IObservable<IList<T>> QuerySegmentedObservable<T>(string tableName) where T : TableEntity,

c# system.reactive reactive-programming 2017-03-07

---

5열

1답변

은 가능한 7 아웃 인 IObservable <T> 발생

C 번호를 작성하는 것입니다 내가 당신이 원하는 무엇이든 할 수 있도록 키워드를 기다리고 그들이 비동기을 열었다 참조하십시오. 그러나 API의 표면적은 very large으로 보이며 제한이 있는지 잘 모르겠습니다. 이 가능한 경우 특히 내가 관심이 내가 전에 논의 Reddit from a while에 대한 링크가 있습니다 public IObservable<

c# asynchronous async-await system.reactive c#-7.0 2017-03-08

---

2열

1답변

한 명령을 다른 명령의 결과에 따라 조건부로 실행하는 방법?

ReactiveUI : CheckNetwork 및 CheckVersion에서 두 개의 명령을 조합했습니다. CheckNetwork가 실행될 때마다 (그리고 정확한 시간에 실행 중) CheckVersion을 실행하고 싶습니다. CheckNetwork가 "true"를 반환 한 경우에만 실행합니다. ReactiveCommand<Unit, bool> CheckNe

system.reactive reactiveui 2017-03-10

---

0열

1답변

반응성 확장 혼란

나는 반응 확장이 무엇인지에 대한 이해가 잘못되었다고 생각하지만 나는 그들이 컬렉션에 메서드 호출을 구독하는 데 사용할 수 있다고 생각했을 것이다. dotnet의 일반적인 이벤트 처리기를 생각하고 있습니다. 내 궁극적 인 목표는 컬렉션이 수정 될 때마다 메서드 호출을 트리거하는 것입니다. 당신은 내가 그 결과를 다시 인쇄하거나이 컬렉션에 추가되는 경우 적어

c# system.reactive 2017-03-12

---

0열

1답변

Reactive Extensions - 관측 가능 범위 내에서 각 onNext 통화 연결 해제

제발 쉽게 나와 함께 가야합니다.이 주제도 배우고 있으며 실제로 즐기고 있습니다. 그래서 여기에 ... 충분한 데이터가 들어오고 나가야하는 "IMyEvent"유형을 나타낼 때 스트림에서 관찰 가능한 읽기를 작성합니다. 해당 유형을 빌드하고 observer.OnNext를 호출합니다. 이 스트림은 서버로부터의 응답 스트림입니다.이 스트림은 내 또는 외부에서이

c# system.reactive 2017-03-13

---

0열

1답변

MassTransit 3 명시 적으로 오류 대기열로 메시지를 보내는 방법

Reactive Extensions로 MassTransit을 사용하여 대기열에서 메시지를 일괄 처리합니다. 동작이 일반 소비자와 같지 않기 때문에 x 번 실패하면 오류 대기열로 메시지를 보낼 수 있어야합니다. 나는 MassTransit 소스 코드를 조사하고 Google 그룹에 게시 했으므로 anwser를 찾을 수 없습니다. ConsumeContext 인터페

system.reactive masstransit 2017-03-15

---