system.reactive

    0热度

    1回答

    “默认”订阅如果在RX模式下（无扩展）无用户

    我已经阅读了这个问题... "Exclusive" and "Default" Subscription Modes in Rx 我的情况很相似。 我喜欢创造类似的东西... class Example { private stativ readonly Subject<Unit> EventStreamSubject = new Subject<Unit>();
    c# .net system.reactive reactive 2017-05-08

    2热度

    2回答

    ReactiveCommand处置后执行

    我使用System.Windows.Interactivity像这样绑定LoadedCommand： <i:Interaction.Triggers> <i:EventTrigger EventName="Loaded"> <i:InvokeCommandAction Command="{Binding LoadedCommand}" /> </i:EventTri
    c# wpf system.reactive reactiveui 2017-05-11

    0热度

    1回答

    一旦第一个observable中的某个项目满足谓词，我该如何合并observables？

    我想取两个观测，并从第一个观察的发射，直到项目之一满足谓词，然后开始发射事件从两者合并，就像这样： letters: -A----B---C----d---------e-----f------g-- numbers: ---1-------2----------3-----4-----5------ predicate: IsLowerCase() result: -A----B--
    c# system.reactive 2017-05-12

    1热度

    1回答

    实现的速度使用`Observable`s

    有限的搜索结果比方说，我有两个Observable S： obs1发出一个搜索框用户输入的结果， obs2需要一个字符串作为输入，并发起一个HTTP请求，然后提供结果 现在，我想通过一些固定的时间间隔限制HTTP请求的数量并不但取决于当obs2与当前请求，像这样做了： 用户类型t，obs2立即开始与t 用户类型te的请求，obs2仍然是 “忙”，什么都不会发生 用户类型tes，obs2仍然是 “忙
    rx-java system.reactive 2017-05-15

    1热度

    2回答

    分割可观察的IEnumerable流<T>延迟反应扩展

    我有以下Rx扩展方法用于分区IEnumerable <T>并延迟生成每个分区值。它使用IEnumerable <T>扩展来划分数据，这也用单元测试显示。 有没有比使用Observable.Timer（）。Wait（）方法调用更好的方式来执行'延迟'？ public static class RxExtensions { public static IObservable<IEnumer
    c# system.reactive 2017-05-17

    0热度

    1回答

    反应rxjs认购不完整

    运行我有对ngOnInit上app.component.ts此功能 `initialiseDb(): Observable <any> { let source = Observable.create((observer) => {} openRequest.onsuccess = (event: any) => { console.log("Databa
    angular typescript system.reactive observable 2017-05-19

    0热度

    1回答

    System.Reactive.Disposables作为独立库

    我实际上学习了有关C＃中的响应，并发现无功提供Disposable类取action（请参阅此link作为源代码）。当调用Dispose时，会触发action。我很喜欢这个想法。 有谁知道是否有一个独立的库提供像对待方式的对象的配置模式？ THX
    .net system.reactive 2017-05-22

    1热度

    1回答

    Rx flatMapLatest没有通过完成？

    我看到timer -> Event completed后我看到running -> Event completed，但它没有发生。 有人可以解释为什么，并给我一些想法如何完成timer观察？ /// playground import RxSwift import PlaygroundSupport PlaygroundPage.current.needsIndefiniteExecuti
    system.reactive rx-swift 2017-05-24

    0热度

    1回答

    DynamicData：TransformToTree

    我有一个应用程序，其中可以通过使用反斜杠（\）字符在层次结构中构建标记。例如 ; Country\Canada\Alberta Country\Canada\British Columbia Country\USA\California Country\USA\Texas 会变成用户界面; Country Canada Alberta British C
    c# wpf system.reactive dynamic-data reactiveui 2017-05-28

    0热度

    1回答

    ManualResetEvent到IObservable <bool>（或WaitHandle到IObservable <Unit>）？

    我想根据ManualResetEvent的Sets/Resets创建一个IObservable-stream，例如，原则上类似于 IObservable<bool> ToObservable(ManualResetEvent ev) { var s = new Subject<bool>(); ev.OnSet += s.OnNext(true); ev.OnRes
    c# multithreading system.reactive 2017-06-01
最新问题