Merge pull request #40 from kpp/examples

Refactor examples

Author: kpp

.github/workflows/rust.yml

@@ -16,7 +16,7 @@ jobs:
     steps:
     - uses: actions/checkout@v2
     - name: build
-      run: cargo build --tests --benches --verbose
+      run: cargo build --tests --examples --benches --verbose
     - name: test
       run: cargo test --verbose
 
@@ -29,7 +29,7 @@ jobs:
       - uses: actions-rs/cargo@v1
         with:
           command: clippy
-          args: --all --lib --tests -- --deny warnings
+          args: --all --lib --tests --examples -- --deny warnings
 
   coverage:
     name: coverage

examples/future.rs

@@ -2,12 +2,12 @@ use futures::executor;
 use futures_async_combinators::future::*;
 
 fn main() {
-    executor::block_on(async {
-        let future = ready(Ok::<i32, i32>(1));
-        let future = and_then(future, |x| ready(Ok::<i32, i32>(x + 3)));
-        let future = inspect(future, |x| {
-            dbg!(x);
-        });
-        assert_eq!(future.await, Ok(4));
+    let future = ready(Ok::<i32, i32>(1));
+    let future = and_then(future, |x| ready(Ok::<i32, i32>(x + 3)));
+    let future = inspect(future, |x| {
+        dbg!(x);
     });
+
+    let res = executor::block_on(future);
+    assert_eq!(res, Ok(4));
 }

examples/stream.rs

@@ -1,12 +1,13 @@
-#![type_length_limit="2111998"]
-
 use futures::executor;
 use futures_async_combinators::stream::*;
 
 fn main() {
     let stream = iter(1..=3);
     let stream = map(stream, |x| x + 1);
     let stream = map(stream, |x| x * 2);
+    let stream = inspect(stream, |x| {
+        dbg!(x);
+    });
 
     let collect_future = collect(stream);
     let collection: Vec<_> = executor::block_on(collect_future);