如何避免在Rx管道中重新執行操作

我有一個Rx管道，根據傳入數據創建一些實體，然後應該保留這些實體並在完成狀態時打印。如何避免在Rx管道中重新執行操作

我試過下面的代碼。問題在於它多次重新執行操作，而不是僅僅一次，因此我在數據庫中獲得了多個實體副本。基本上用下面的代碼，我想打印「堅持test1」只有一次。

 var test1Observable = Observable.Return("test1"); 
     var test2Observable = Observable.Return("test2"); 

     var createTest1Observable = test1Observable.Select(name => name); 
     var test1 = createTest1Observable.Do(x => Console.WriteLine("persisting test1")); 

     var createTest3Observable = Observable.CombineLatest<string, string, Tuple<string,string>>(test1, test2Observable, (t1, t2) => new Tuple<string,string>(t1,t2)); 
     var persistTest3Observable = createTest3Observable.Do(x => Console.WriteLine("persisting test 3")); 

     var createTest4Observable = test1.Select(x => "test4"); 
     var persistTest4Observable = createTest4Observable.Do(x => Console.WriteLine("persisting test 4")); 

     var createTest5Observable = test1.Select(x => "test5"); 
     var persistTest5Observable = createTest5Observable.Do(x => Console.WriteLine("persisting test5")); 

     var OnSuccesObservable = Observable.CombineLatest<string, Tuple<string,string>, string, string, bool>(test1, persistTest3Observable, persistTest4Observable, persistTest5Observable, (t1, t2, t3, t4) => 
     { 
      if (t1 == null || t2 == null || t3 == null || t4 == null) 
       return false; 
      else 
       return true; 
     }); 

     OnSuccesObservable.Subscribe(
      o => 
      { 
       Console.WriteLine("Finished"); 
       Console.ReadLine(); 
      });

來源

2015-04-23 user3115696

'var persistTest2Entity = createTest1Entity.Do（persistor）;' - 應該是createTest * 2 * Entity 。做（...）？ –

是的，對不起，我現在編輯並修正了這個問題中的拼寫錯誤。但它並沒有解決問題。 – user3115696

我意識到我的初始代碼示例有點太簡化了，並沒有顯示出那麼好的問題，所以我編輯了它，以便它顯示得更好。代碼多次打印「持久test1」，但我希望它只發生一次。 – user3115696

嘗試使TEST1可連接的可觀察到的

var test1 = createTest1Observable.Do(x => Console.WriteLine("persisting test1")).Publish();

然後在所有的其他代碼連接到它如下

var connected = test1.Connect();

這確保了可觀察到的是共享的正確和不重新訂閱

來源

2015-04-24 10:03:25

這裏的一個很好的解釋http://www.introtorx.com/content/v1.0.10621.0/14_HotAndColdObservables.html –

這確實似乎解決了這個問題。謝謝。我將不得不更多關注可連接的可觀察性如何工作。 – user3115696

如何避免在Rx管道中重新執行操作

回答

相關問題