system.reactive

Вопрос или проблема У меня есть метод расширения, определенный в библиотеке классов (назовем ее My.Extensions.Reactive): public static class ObservableExtensions { /// <summary> /// Возвращает последовательность, которая генерируется путем сравнения

Вопрос или проблема Я пытаюсь разработать библиотечный паттерн, который позволяет потребляющему коду выполнять следующее: // некоторая логика // ждать, пока условие в предикате станет истинным, в соответствии с источником данных await dataSource.Where(SomePredicate).AsObservable().FirstAsync().ToTask();