system.reactive

2열

1답변

ReactriveX : 람다 식으로 관찰 가능한 <bool>에 예외를 잡기

나는했습니다이 관찰 : 현재 public class NetworkToolEngine { public NetworkToolEngine() { this.connectionAvailable = Observable .Interval(TimeSpan.FromSeconds(5)) .Select(_ => tr

c# system.reactive 2017-11-09

---

0열

1답변

IObservable이 한 번만 열거/실행되도록하는 방법

나는 비동기 작업을 수행하고 관찰 가능한 시퀀스에 결과를 게시하는 ICommand을 작성하고 있습니다. 결과는 게으르다. 누군가가 결과에 동의하지 않으면 아무 일도 일어나지 않는다. 사용자가 결과에 대한 구독을 취소하면 취소됩니다. 아래 코드는 (대단히 단순화 된) 일반적으로 작동합니다. 까다로운 점은 Execute를 호출 할 때 결과에 ​​많은 구독자가

c# system.reactive 2017-11-10

---

2열

1답변

왜 관측 가능하지 않습니까? 마지막으로 전화가 왔습니까?

나는 Finally 메서드를 이해하지 못한다. 이 상황에서는 발사되지 않습니다. [TestMethod] public void FinallyHappensOnError() { bool finallyActionHappened = false; try { Observable .Throw<Unit>(new Divid

c# system.reactive 2017-11-10

---

0열

1답변

Rxjs 초기화 자원은 한 번 뜨거운 관찰

와 나는 다음이 코드 서비스 설정을 가지고 : @Injectable() export class StaticResourcesService { private resourcesTree$: Observable<any>; getSpecificLabel(resourceName: string, type: string): Observable<string> {

angular typescript rxjs observable system.reactive 2017-11-13

---

0열

1답변

Rx .Net을 사용하여 데이터 파이프 라인을 만들려고 시도합니다.

Rx .Net을 사용하여 일부 데이터를 파이프 라인으로 보내려고했지만 정말 어려움을 겪고 있습니다. 데이터가있는 저장되지 않은 Foos가 있습니다. Foos는 모음 모음을 만듭니다. 바가 저장된 후에 Bar에 BarId가 있으면 Foo의 데이터와 Bar의 BarId를 사용하여 Baz를 작성합니다. Foo의 Bars와 Baz가 모두 만들어지면 Foo의 데이터

c# system.reactive reactive-programming 2017-11-15

---

2열

1답변

가장 가까운 값으로 관찰 가능

I kotlin의 확장 기능으로 "FilterByLatestFrom"이라는 의사 연산자를 구현했습니다. fun testFilterByLatestFromOperator(){ val observableA : Observable<Int> = Observable.fromArray(1,2,3,4,5,6,7,8,9,10) val observableC

kotlin rx-java system.reactive publishsubject 2017-11-17

---

0열

1답변

Observable.Timer의 '진보'를 얻을 수있는 방법이 있나요

현재 나는이 시간이 남아있는 관찰 가능한 기반으로 카운트 다운을 표시하고 싶지만 찾을 수 없습니다 Observable.Timer(TimeSpan.FromSeconds(5)) .Subscribe(x => MessageBroker.Default.Publish(new Messages.Serve())); 예상대로이 작업이 타이머 현재 값에 액세스하

c# unity3d system.reactive 2017-11-20

---

0열

1답변

Rx.NET의 RxJS throttleTime과 같습니다.

Rx.NET을 사용하여 RxJS throttleTime을 구현하려고합니다 (.NET에서는 구현되지 않았습니다). throttleTime은 Observable 소스에서 값을 내 보낸 다음 계속되는 밀리 초 동안 소스 값을 무시한 다음이 프로세스를 반복합니다. 이것은 방출되기 전에 대기하는 throttle과 다릅니다. throttleTime은 첫 번째 항목을

system.reactive 2017-11-23

---

2열

1답변

IObservable <double>의 값을 변경하는 방법은 무엇입니까?

저는 RX에서 새로 왔습니다. 지금은 쉬운 일을하려고합니다. 단지 새로운 값을 IObservable에 설정하려고합니다. (제 경우에는 T가 두 배입니다). 그것을하는 방법? 콘솔에 Subject<double> subject = new Subject<double>(); IObservable<double> observable = subject.AsObserv

c# system.reactive 2017-11-23

---

1열

2답변

Observable과 State를 쌍으로 만드는 방법은 무엇입니까?

Rx.Net을 배우고 있으며 수많은 간격으로 실행되는 스케줄러를 만들고 있습니다. 개념은 내가 간격의 모음과 명령의 모음을 가지고 있고, 그것들을 하나로 묶고 병합 된 결과에 구독한다는 것이다. 각 명령은 해당 간격과 연관되며 연관과 함께 정의 된 간격 (종지)에 실행됩니다. 간격을 병합 할 수 있지만이 명령 (상태)을 구독에 전달하는 방법을 파악하는 데

.net system.reactive reactive 2017-11-27

---