system.reactive

    2열

    1답변

    장기 실행 프로세스에서 ReactiveUI, Observables, SubscribeOn 및 ObserveOn을 사용하여 UI에서 출력 로그를 표시합니다.

    상태를 푸시 위해 System.Reactive.Subject<string>을 사용하는 장기 실행 작업 (60 초 이상)을 실행할 WPF 응용 프로그램이 있습니다. 메시지를 주기적으로 보냅니다. 아이디어는 내 ViewModel에서 관측 가능을 구독하고 ReactiveUI가 자동으로 데이터 바인딩을 통해 UI를 업데이트하도록 할 수 있다는 것이 었습니다. Te
    c# .net wpf multithreading system.reactive 2017-01-19

    1열

    1답변

    C에서 RX로 자동 저장

    자동 저장 기능을 구현하고 싶습니다. IObservable<Unit> changes : 나는 두 Observable 인이하는 항목을 사용자가 텍스트 IObservable<Unit> saves을 편집 할 때마다 방출 : 방출하는 이벤트를 내가 결합하려는 저장 버튼 지금 을 누를 때마다 시간을 절약 제 3의 스트림에 들어가는 사람 writeBack. 이 스트림
    c# system.reactive autosave rx.net 2017-01-22

    0열

    2답변

    IObservable을 사용한 대화 상호 작용 요청

    반응 형 프로그래밍을 사용하여 MVVM 응용 프로그램을 빌드하고 내보기 모델이 질문을 제기하고 대화를 기다리는 대화 상자가 표시 될 때까지 기다리고 있습니다. 예를 들어 사용자가 이름 바꾸기 버튼을 클릭하면 사용자가 텍스트를 변경할 수있는 대화 상자가 나타납니다. 내 접근 방식은 뷰 모델에 IObservable<string> 속성을 노출하는 것입니다. 뷰의
    system.reactive 2017-01-23

    1열

    1답변

    Grpc - rx observable 사용

    GRPC 스트림을 통해 관찰 가능 항목을 표시하려고합니다. 내 간단한 코드는 다음과 같습니다 public override async Task Feed(Request request, IServerStreamWriter<Response> responseStream, ServerCallContext context) { var result
    system.reactive grpc 2017-01-23

    1열

    2답변

    Reactive Extensions : 다른 스트림이 완료 될 때까지의 버퍼

    요청을하고 응답 스트림에서 해당 요청에 대한 응답을 기다립니다. 기다리는 동안 업데이트 스트림에 업데이트가있을 수 있습니다. 응답 스트림이 완료되면이 업데이트를 받고 싶습니다. 좋아요 : Response (cold) | x y z | Updates (hot) | 1 2 3 4 | Result | x y z 123 4 | 나는 제대로 할
    .net system.reactive 2017-01-23

    0열

    1답변

    는 UI 요소가 오류

    가이 코드 Dim observ As IObservable(Of Long) = System.Reactive.Linq.Observable.Interval(TimeSpan.FromSeconds(10)) Dim source As New System.Threading.CancellationTokenSource() Dim action As Actio
    wpf vb.net system.reactive 2017-01-24

    0열

    1답변

    각 간격마다 내 onNext 값을 제공하는 대신 내 버퍼 된 관찰 가능 항목을 완료하는 이유는 무엇입니까?

    Observable이 processedMessages입니다. 메시지를 버퍼링하고 10 개의 메시지마다 또는 30 초마다 외부 큐에서 메시지를 삭제해야합니다. 이 코드는 내 서비스의 생성자에 의해 불려 this.processedMessages.Where(m => m != null && some criteria here) .Buffer(TimeSpan
    .net system.reactive 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

    1열

    2답변

    Rx에서 관찰 가능한 상태를 유지하는 최적의 방법

    관찰 가능한 상태를 유지하기 위해 RxJava 패턴이 더 좋은지에 대한 질문이 있습니다. 간단하게하기 위해 시스템에서 특정 상태 (불리언 플래그라고 가정 해 봅시다)를 추적하고이를 관찰 가능한 방식으로 노출해야하는 StateManager 클래스가 있다고 가정 해 봅시다. 이 관리자는 매우 긴 수명을 가지고 class StateManager { Ob
    rx-java system.reactive 2017-01-31

    0열

    2답변

    모든 구독이 종료 된 시간 받기

    여러 구독을 만들고 있습니다. 조치를 수행하기 위해 (모든) 완료되었을 때를 감지해야합니다. private IList<IDisposable> subscriptions = new List<IDisposable>(); private void CreateSubscriptions(IEnumerable<int> integers) { if (this.s
    c# system.reactive 2017-02-02
최근 질문