From caa8988bfa040f42d481b7b193ae04da0ddd530f Mon Sep 17 00:00:00 2001
From: Patrick Reisert <kpreisert@gmail.com>
Date: Sat, 18 May 2019 15:30:33 +0200
Subject: [PATCH] Expand example

---
 examples/async.rs | 46 ++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git a/examples/async.rs b/examples/async.rs
index 5896ae1..88e7557 100644
--- a/examples/async.rs
+++ b/examples/async.rs
@@ -16,6 +16,8 @@ use winrt::*;
 use winrt::windows::foundation::*;
 use winrt::windows::devices::enumeration::*;
 use winrt::windows::devices::midi::*;
+use winrt::windows::media::*;
+use winrt::windows::storage::StorageFile;
 
 fn main() {
     let rt = RuntimeContext::init();
@@ -78,4 +80,48 @@ async fn run() {
         let device_name = current.get_name().unwrap();
         println!("Device Name ({}): {}", i, device_name);
     }
+
+    print!("Transcoding media: ");
+    let source = StorageFile::get_file_from_path_async(&*FastHString::new("D:\\Desktop\\test-transcode\\test.mp3")).unwrap().await.expect("get_file_from_path_async failed").unwrap();
+    let dest = StorageFile::get_file_from_path_async(&*FastHString::new("D:\\Desktop\\test-transcode\\test.flac")).unwrap().await.expect("get_file_from_path_async failed").unwrap();
+    let profile = mediaproperties::MediaEncodingProfile::create_flac(mediaproperties::AudioEncodingQuality::Medium).unwrap().unwrap();
+    let transcoder = transcoding::MediaTranscoder::new();
+    let prepared = transcoder.prepare_file_transcode_async(&source, &dest, &profile).unwrap().await.unwrap().unwrap();
+    assert!(prepared.get_can_transcode().unwrap());
+
+    let mut interval = Interval::new(Duration::from_millis(100));
+    let async_op = prepared.transcode_async().unwrap();
+    // TODO: there should be a way to await the created AsyncActionProgressHandler (and any other delegate) as an async stream
+    async_op.set_progress(&AsyncActionProgressHandler::new(|_info, progress| {
+        print_progress(progress);
+        Ok(())
+    })).unwrap();
+    let mut async_op = async_op.fuse();
+
+    let work = async {
+        let mut result = None;
+        loop {
+            select! {
+                _ = interval.next() => {
+                    use std::io::Write;
+                    print!(".");
+                    std::io::stdout().flush().unwrap();
+                },
+                res = async_op => {
+                    result = Some(res);
+                    println!("");
+                    break;
+                }
+            };
+        }
+        result.unwrap()
+    };
+
+    work.await
+}
+
+fn print_progress(progress: f64) {
+    use std::io::Write;
+    print!("{:.0}%", progress);
+    std::io::stdout().flush().unwrap();
 }