RXエクステンションToObservable（）はネストされたIColletionを照会する際に例外を発生させます

Question

私はちょうどefとrxの使用に慣れようとしています。残念ながら、私は解決できない問題に遭遇しました。私はworld.sqlと呼ばれるMySQL用のテストデータベースを持っています。 EFは以下を生成しました

public worldEntities() 
     : base("name=worldEntities") 
    { 
    } 

    protected override void OnModelCreating(DbModelBuilder modelBuilder) 
    { 
     throw new UnintentionalCodeFirstException(); 
    } 

    public virtual DbSet<city> city { get; set; } 
    public virtual DbSet<country> country { get; set; } 
    public virtual DbSet<countrylanguage> countrylanguage { get; set; } 

私は今、Rxが提供する "単純な" LinqクエリとToObservable（）代替を比較しようとしていました。

var m = new worldEntities(); 
     var res = m.country.Where(e => e.countrylanguage.Any(i=>i.Language.Equals("German"))).Select(e => e.Name); 

しかし、私は受信の対応を把握することはできません。LINQのを使用して、私は作品次のクエリを持っています。私は同じアプローチに

var set = m.country.ToObservable(); 
     set.Where(e => e.countrylanguage.Any(i => i.Language.Equals("German"))) 
      .Select(e => e.Name).Buffer(50). 
      Subscribe(l=> 
      Items.AddRange(l)); 

を使用してみた場合、私は、次の内部のメッセージで例外が発生します：

{"There is already an open DataReader associated with this Connection which must be closed first."} 

だから私の質問は、どのようにRXのクエリは同じ結果を達成するために、のようになりますされます。

ありがとうございました。

Answer 1

おそらくそのような何かが動作するはずです：

var set = m 
.country 
.Where(e => e.countrylanguage.Any(i => i.Language.Equals("German"))) 
.Select(e => e.Name) 
.ToObservable(); 
      set.Buffer(50). 
       Subscribe(l=> 
       Items.AddRange(l)); 

それは間違いなく「慣れる」ための最良のものではないRXの拡張のための非常に珍しいのアプリケーションです。しかし。

Answer 2

データベースはプルベースのシステムです。データベースからデータを取得するように要求します。 Rxはプルリクエストではなく、プッシュリクエストを処理することに関するものです。これはRxの使い方ではありません。

Rxを学びたい場合は、Rxをイベント処理に使用してください。