rx.net

0열

1답변

System.Web.Http 끝점을 IObservable로 설정할 수 있습니까?

System.Web.Http 끝 점이 IObservable 일 수 있습니까? Route 및 AcceptVerbs와 같은 속성을 사용하면서 수행 할 수 있습니까? 는 기본적으로, 내가 가입 및 반응 확장을 통해 처리하고 있습니다 있도록 IObservable 스트림에 다음 코드 예제를 만들고 싶어 : [Route("{id}")] [AcceptVerbs

c# system.reactive rx.net 2017-11-06

---

0열

1답변

내가 어느 정도 정상적인 조절 이상으로 조금 이동 관찰 스트림을위한 특별한 필요/요구 사항으로 가지고 있고 그것을 수행하는 방법에 완전히 확실하지 않다 창

RX.net .Throttle() '슬라이딩' 나는 평소, 연속해서 일어날 수있는 이러한 이벤트로 이제 var someEventObservable = Observable.FromEventPattern<SomeEventHandler, SomeEventArgs>( handler => this.ColumnWidthChanged += handler,

c# system.reactive reactive-programming rx.net 2017-09-21

---

0열

1답변

RPL 사용/사용하지 않음 tpl 데이터 흐름

TPL 데이터 흐름과 함께 .net reactive 확장명을 사용하고 있습니다. 다음은 내 파이프 라인입니다. 데이터 소스를 일부 외부 소스에서 스트림으로 가져 오는 중 dataflow TransformBlocks를 사용하여 데이터 포인트를 변환합니다. 이 후에 Rx 버퍼를 사용하여 1 초 동안 버퍼링 된 점을 버퍼링하고 마지막으로 데이터 흐름 Action

c# tpl-dataflow rx.net 2017-01-27

---

4열

2답변

Reactive Extensions를 사용하여 주를 어떻게 폴링합니까?

이미 내가 비슷한 질문이 반응성 (Database polling with Reactive Extensions) 를 사용하여 데이터베이스 폴링에 좋은 질문이 있습니다,하지만 트위스트와 함께 : 나는 다음 요청으로 이전 결과에서 값을 공급해야합니다. 기본적으로,이 폴링 싶습니다 : interface ResultSet<T> { int? CurrentA

c# system.reactive rx.net 2017-01-27

---

0열

1답변

Rx.Net : 관찰 비동기 이벤트는 indifinitely

나는 로컬 파일 시스템에 문자 메시지를 저장하는 헬퍼 클래스가 있습니다. 이 메서드는 Task 개체를 반환하며 정의에 따라 비동기입니다. 나는이 메소드가 호출 될 때 관찰 할 수 있도록하려면, 그래서 지속적으로 그 기반으로 결정을 버퍼의 크기와 길이를 모니터링 할 수 있습니다. 나는 .NET에 대한 반응성 확장을 사용하여이를 구현하기 위해 노력하고 있습니다

c# asynchronous rx.net 2017-03-19

---

0열

1답변

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

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

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

---

0열

1답변

Reactive Extensions ToEnumerable 모든 것을 반복하지 않으면 관찰 가능한 상태를 처리하는 방법

IObservable에서 ToEnumerable 확장자를 사용하면 사용자가 모든 요소를 ​​반복하지 않을 수 있습니다. 이 경우 Observable.Create에 IDisposable이 (가) 적절하게 처리 될 수 있습니까? IObservable을 사용자에게 직접 반환하는 옵션이 없다고 가정 해 봅시다.이 경우 사용자가 직접 취소를 구현할 수 있습니다. p

c# system.reactive rx.net 2017-05-11

---

2열

2답변

수신 .NET 힘 버퍼는

내가 수신 버퍼 기능을 사용할 방출하기 : 버퍼가 마지막 발광 이후 갈 5 또는 30 초 크기에 도달하면 발광 (가입자에 게시)을 의미 var source = new Subject<Price>(); var buffer = source .Buffer(TimeSpan.FromSeconds(30), 5) .Where(p => p.Any());

c# system.reactive rx.net 2017-10-11

---

1열

1답변

뜨거운 관측 가능 및 IDisposable

뜨거운 관측 가능 및 IDisposable 개체에 대한 우수 사례를 이벤트 유형으로보고 싶습니다. 내 코드가 뜨겁게 관찰 할 수있는 Bitmap 객체를 생성한다고 가정하고 몇 명의 가입자가 있습니다. 예를 들어 : public static IObservable<Bitmap> ImagesInFolder(string path, IScheduler schedul

c# system.reactive rx.net 2017-05-17

---

2열

1답변

Xamarin에서 Rx로 이벤트 브리징

현재 버튼에 클릭 이벤트에 대한 일반 오래된 위임자/이벤트 관찰자 패턴을 사용하고 있습니다. 그래서 저는 Rx에 갈 것이라고 생각했습니다. 첫 번째 시도는 공이었습니다. 나는 당신이 윈폼의 예에서 볼 수있는 간단한 과부하 갈 거라고 생각 : Observable.FromEventPattern<EventArgs>(__navToTestButton, 'click'

xamarin xamarin.android rx.net 2017-12-09

---