Реактивных расширения: Создание трубопровода с Rx, который работает с файлами

Question

У меня есть процесс трубопровод с 3 этапом:

1. видео к изображениям: У меня есть видео, которое преобразуется в стоп-кадры (фреймы)
2. Кадры для zip-файла: Когда все кадры в видео обработаны, я должен создать с ними Zip-файл.
3. зип файл => Загрузить на FTP

Она включает в себя 2: одноразовые видео захвата и почтовый файл.

Как я могу справиться с этим с помощью Rx? Есть идеи? Извините, что не публиковал какой-либо код, я не знаю, с чего начать.

Заранее благодарен!

Answer 1

Вам нужно пройти по необработанным объектам с каждого шага. Должно быть хорошо, что захват видео или zip-файл «удалены», потому что я уверен, что будет какое-то побочное действие, связанное с действием (MemoryStream, файл, записанный на диск и т. Д.). Вы можете просто передать указатели (Uri's?) К результатам каждого действия к следующей части конвейера?

void Main() 
{ 
    var video = new Uri("https://www.youtube.com/watch?v=Tp5mRlHwZ7M"); 
    var query = from frames in TranscodeVideoToImages(video) 
     from zipFile in ZipFiles(frames) 
     from uploadLocation in UploadFile(zipFile) 
     select uploadLocation; 
    query.Subscribe(...) 
} 
private IObservable<Uri[]> TranscodeVideoToImages(Uri imageSource) 
{ 
    //Do some long running (async) work here. 
    // Save work to disk 
    // Return location of saved work 
} 
private IObservable<Uri> ZipFiles(Uri[] files) 
{ 
    //Run the zip process on all of the files 
    // Return the location of the zip file 
} 
private IObservable<Uri> UploadFile(Uri source) 
{ 
    //Upload the File. 
    //Probably as simple as as task based operation with .ToObservable() 
}