system.reactive

0열

1답변

어떻게 그룹화 된 관측 값을 올바르게 재결합합니까?

저는 주가 분석을위한 도구를 만들려고합니다. 다른 주식에 대한 가격 데이터 스트림이 있는데, 새롭고 별개의 완전한 가격 집합을받을 때마다 이벤트를 내 보내고 싶습니다. 내 계획 : 다른 주식에 대한 스트림을 다른 하위 스트림으로 그룹화하고 최신 값을 재결합합니다. a_source = price_source.filter(lambda x: x['stock']

python-3.x system.reactive reactive-programming reactivex rx-py 2017-05-06

---

0열

1답변

"기본"가입 이미이 질문을 읽어

수신 (반응성 확장)에는 가입자 ... "Exclusive" and "Default" Subscription Modes in Rx 내 경우는 매우 유사없는 경우. 나는 그런 일을 만들려면 ... class Example { private stativ readonly Subject<Unit> EventStreamSubject = new S

c# .net system.reactive reactive 2017-05-08

---

0열

1답변

동시에 듣고있는 동안 subscribe 함수를 주기적으로 호출하십시오.

실례 합니다만 실례 합니다만 Reactive extensions에 약간의 경험이 있습니다. 내가 원하는 것은이 같은 것입니다 : 항목을 항상 방출이 관측 주어진 myObservable.Do(d => myObserver.OnNext(d)).Interval(someTime).subscribe({ Run the this code periodically with

c# asynchronous system.reactive reactive-programming 2017-05-10

---

0열

1답변

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

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

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

---

-1열

1답변

속성에 의해 호출 된 메서드에 대한 리 액티브 확장

이전에는 ReactiveExtensions를 사용 해본 적이 없었습니다. 나는 온라인으로 보았고 정말로 나의 필요에 맞는 길을 발견 할 수 없었다. 모든 예는 내가 달성해야하는 것과 비교하면 약간 과장된 것처럼 보입니다. 나는 나를 위해 모든 것을하는 방법이 있으므로 값을 반환하고 내 목록을 설정하지 않아도됩니다. 사용자가 타이핑하는 동안 사용자가 타이핑을

c# wpf system.reactive 2017-05-16

---

1열

1답변

뜨거운 관측 가능 및 IDisposable

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

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

---

1열

2답변

Reactive Extensions에서 지연되는 IEnumerable <T>의 관찰 가능한 스트림을 분할

IEnumerable을 <T>으로 분할하고 각 분할 된 값의 생성을 지연시키는 다음 Rx 확장 방법이 있습니다. IEnumerable <T> 확장명을 사용하여 데이터를 분할하며 단위 테스트와 함께 표시됩니다. Observable.Timer()를 사용하는 것보다 '지연'을 수행하는 더 좋은 방법이 있습니까? Wait() 메소드가 호출 되었습니까? 수신 확장

c# system.reactive 2017-05-17

---

0열

1답변

System.Reactive.Disposables as Standalone library

사실 C#에서 반응이 있음을 알게되었고 Disposable 클래스는 action (소스 코드는 link 참조)입니다. Dispose이 호출되면 action이 발생합니다. 나는이 아이디어가 맘에 든다. 개체에 처분 패턴을 제공하는 독립 실행 형 라이브러리가있는 경우 누구에게 알 수 있습니까? 여기 들으

.net system.reactive 2017-05-22

---

2열

1답변

가능한 한 빨리 요청과 출력 결과를 결합하십시오.

짧은 버전 : Akavache를 추가하지 않은 상태에서처럼 내 코드 (https://github.com/akavache/Akavache/blob/501b397d8c071366c3b6783aae3e98695b3d7442/src/Akavache/Portable/JsonSerializationMixin.cs#L202)에 Akavache와 같은 GetAndFetc

c# system.reactive reactive-programming 2017-05-23

---

4열

1답변

반응 프로그래밍을 사용하여 FileStream을 열어 쓰기 위해 작성

작은 로거를 작성 중이며 로그 파일을 한 번 열어서 로그 메시지가 도착하면 응답을 계속 작성하고 프로그램 종료시 모든 내용을 처리하려고합니다. FileStream을 열린 상태로 유지할 수있는 방법이 확실하지 않습니다. 및 메시지가 도착하면 반응적으로 작성합니다. 큐를 사용하는 using 문 내부의 루프와 버퍼로 동작하는 ConcurrentQueue가있는 이

c# system.reactive filestream tpl-dataflow 2017-09-04

---