На злобу дня: кроссплатформенный клиент для Telegram на .NET Core и Avalonia

Как и в большинстве GUI фрэймворков, Avalonia позволяет выполнять действия с элементами пользовательского интерфейса только с UI-потока. На этом потоке желательно выполнять минимум работы, чтобы приложение оставалось отзывчивым. С приходом async/await делегировать выполнение работы в другие потоки стало намного проще.

Мне в коде очень не нравится вот это место:

u.Contact.Avatar = u.Avatar;

Здесь что u.Contact, что u.Avatar — это объект который пришел от к NavContext от ContactLoader. Про них обоих ContactLoader знает. Так с какого перепугу установка свойства Avatar оказалась в ответственности NavContext?

Зачем вообще ContactLoader возвращает объект который можно обработать одним-единственным способом? Чтобы больше boilerplate писать?..

Надо или присваивание перенести в NavContext, или убирать свойство Avatar из DTO контакта.

Еще замечания, не очень критичные.

Код внутри Observable.Create будет выполняться в потоке UI, потому что именно в нем происходит подписка. Однако в текущей версии ему доступ к UI не нужен, так что для ускорения его желательно выгнать в фоновой поток:

return Observable.Create(async observer =>
{
    // ...
}).SubscribeOn(Scheduler.Default);

Также можно убрать все вызовы OnComplete: асинхронная версия Observable.Create сама вставит их когда завершится задача.

public class ContactsViewModel : ReactiveObject
{
  private ReactiveList<Contact> _contacts;
  public ReactiveList<Contact> Contacts
  {
    get => _contacts;
    private set => this.RaiseAndSetIfChanged(ref _contacts, value);
  }
}

[AddINotifyPropertyChangedInterface]
public class ContactsViewModel 
{
  public ReactiveList<Contact> Contacts { get; private set; } 
}

Что-то домен egram.tel не резолвится.

  async Task<Load> LoadContacts()
  {
      var contacts = await GetContactsAsync();
      var avatarUpdatesStream = contacts
        .ToObservable()
        .SelectMany(contact => GetAvatarAsync(contact)
            .ToObservable()
            .Select(avatar => new Update(contact, avatar))        
        );
      return new Load(contacts, avatarUpdatesStream)
  }

  IObservable<Load> LoadContacts() =>  
    GetContactsAsync()
        .ToObservable()
        .Select(contacts =>
        {      
            var avatarUpdatesStream = contacts
            .ToObservable()
            .SelectMany(contact => GetAvatarAsync(contact)
                .ToObservable()
                .Select(avatar => new Update(contact, avatar))
            )
            return new Load(contacts, avatarUpdatesStream)
        });