1

刚开始使用 ReactiveUI。我基本上是用查询结果填充网格。我的视图模型目前看起来像这样。

 public class QueryViewModel : ViewModelBase 
{

    private readonly ResultSet _resultSet = null;

    public ReactiveCollection<GridColumn> Columns { get; private set; }
    public ReactiveCollection<GridRow> Rows { get; private set; }

    public QueryViewModel()
    {
        _resultSet = ... run query

        Columns = new ReactiveCollection<GridColumn>(from c in _resultSet.Columns select new GridColumn(c));
        Rows = new ReactiveCollection<GridRow>(from r in _resultSet.Rows select new GridRow(r));

        //Rows = new ReactiveCollection<GridRow>();
        //_resultSet.ObservableRows
        //          .Subscribe(r => Rows.Add(new GridRow(r)));                     

    }    
}

正如您所看到的，我可以在使用 IEnumerable 填充时使其工作，但您可以从注释掉的位中看到，我不太确定从 IObservable 填充的方式。

任何机会有人可以指出我正确的方向，拜托。

编辑：

为了全面披露，我已经包含了 ObservableRows 的实现，以防我在这里犯了错误。

Return Observable.Create<Row>((o) => {
             var cn = New SqlConnection(connection);
             var cmd = New SqlCommand(sql, cn);
             var asyncReader = Observable.FromAsyncPattern<SqlDataReader>(cmd.BeginExecuteReader, cmd.EndExecuteReader);
             IDisposable subscription;
             Try {
                cn.Open();
                subscription = asyncReader().Subscribe(rdr => PublishRows(rdr, o, columns));
             }
             Catch Exception ex {
                o.OnError(ex);
             }

             Return Disposable.Create(() => { 
                  subscription.Dispose();
                  cmd.Dispose();
                  cn.Close();
                  cn.Dispose();
             });
}

很多谢谢

小号

4

1 回答 1

3

怎么样：

Rows = _resultSet.ObservableRows.CreateCollection();
于 2013-02-03T00:14:08.980 回答