从DataService MVVM Light持续更新ViewModel

Question

最初我的ViewModel有以下内容：

    public ObservableCollection<DataListItem> files { get; private set; }
    private object _filesLock = new object();
    public MainViewModel(IDataService dataService)
    {
        files = new ObservableCollection<DataListItem>();
        BindingOperations.EnableCollectionSynchronization(files, _filesLock);
        _dataService = dataService;
    }

其中一个命令运行此代码

            await Task.Run(() => {
                Parallel.ForEach(files, new ParallelOptions() { MaxDegreeOfParallelism = 2 }, (file) =>
                {                    
                    this.files.Add(new DataListItem(file));
                });
            });

但这在设计时不起作用。所以我把代码移到了DataService中。

    public async void ScanFolder()
    {
        if (!CanScanFolder()) return;
        files.Clear();
        await Task.Run(() =>
        {
            _dataService.GetData(SelectedFolder, filter, IncludeSubs, (myfiles, error) =>
                {
                    if (error != null)
                    {
                        return;
                    }
                    foreach (var file in myfiles.files)
                    {
                        files.Add(file);
                    }
                }
                );
        });            
    }

DataService代码如下

    public async void GetData(string folder, string filter, bool includeSubs, Action<DataItem, Exception> callback)
    {
        // Use this to connect to the actual data service
        var item = new DataItem(folder, filter, includeSubs);
        await item.ScanFolderAsync();
        callback(item, null);
    }
    public async Task<bool> ScanFolderAsync()
    {
        try
        {
            var ret = new List<DataListItem>();
            var files = Directory.EnumerateFiles(folder, filter, includeSubs ? SearchOption.AllDirectories : SearchOption.TopDirectoryOnly);
            await Task.Run(() => {
                Parallel.ForEach(files, new ParallelOptions() { MaxDegreeOfParallelism = 2 }, (file) =>
                {                    
                    this.files.Add(new DataListItem(file));
                });
            });
            return true;
        }
        catch (Exception)
        {
            return false;
        }
    }

但据我所知，在DataService和ViewModel之间没有持续的通信通道。因此，使用新方法，它会读取所有文件，然后将其显示在网格中，但我希望它在每次更新时都能显示出来。

我的直觉是在foreach中添加一个Messenger，并在ViewModel中订阅它，但似乎没有办法在数据服务中使用Messenger。

DataService如何在每次扫描文件时向ViewModel发送消息？或者，是否有更好的架构来加载数据？

Answer 1

原来我只是缺少信使的using语句，可以使用它更新ViewModel。

在ViewModel构造函数中，我添加了

Messenger.Default.Register<DataListItem>(this, (item) => { files.Add(item); });

并且更新了ScanFolderAsync（）方法以发送消息

using GalaSoft.MvvmLight.Messaging;
public async Task<bool> ScanFolderAsync()
{
     try
     {
        var ret = new List<DataListItem>();
        var files = Directory.EnumerateFiles(folder, filter, includeSubs ? SearchOption.AllDirectories : SearchOption.TopDirectoryOnly);
        await Task.Run(() => {
                Parallel.ForEach(files, new ParallelOptions() { MaxDegreeOfParallelism = 1 }, (file) =>
            {
                var item = new DataListItem(file);
                Messenger.Default.Send<DataListItem>(item);
                this.files.Add(item);
            });
       });
        return true;
    }
    catch (Exception)
    {
        return false;
    }
}