diff options
Diffstat (limited to 'ipfs-api/examples')
| -rw-r--r-- | ipfs-api/examples/bootstrap_default.rs | 22 | ||||
| -rw-r--r-- | ipfs-api/examples/get_version.rs | 2 | ||||
| -rw-r--r-- | ipfs-api/examples/mfs.rs | 70 | ||||
| -rw-r--r-- | ipfs-api/examples/ping_peer.rs | 2 |
4 files changed, 47 insertions, 49 deletions
diff --git a/ipfs-api/examples/bootstrap_default.rs b/ipfs-api/examples/bootstrap_default.rs index bc36952..e03c5d6 100644 --- a/ipfs-api/examples/bootstrap_default.rs +++ b/ipfs-api/examples/bootstrap_default.rs @@ -46,19 +46,19 @@ fn main() { }); let fut = bootstrap - .and_then(|_| { - println!(); - println!("dropping all bootstrap peers..."); + .and_then(|_| { + println!(); + println!("dropping all bootstrap peers..."); - drop - }) - .and_then(|_| { - println!(); - println!("adding default peers..."); + drop + }) + .and_then(|_| { + println!(); + println!("adding default peers..."); - add - }) - .map_err(|e| eprintln!("{}", e)); + add + }) + .map_err(|e| eprintln!("{}", e)); #[cfg(feature = "hyper")] hyper::rt::run(fut); diff --git a/ipfs-api/examples/get_version.rs b/ipfs-api/examples/get_version.rs index 6fb9c7e..d8b0f65 100644 --- a/ipfs-api/examples/get_version.rs +++ b/ipfs-api/examples/get_version.rs @@ -27,7 +27,7 @@ fn main() { .map(|version| println!("version: {:?}", version.version)); let fut = req.map_err(|e| eprintln!("{}", e)); - + #[cfg(feature = "hyper")] hyper::rt::run(fut); #[cfg(feature = "actix")] diff --git a/ipfs-api/examples/mfs.rs b/ipfs-api/examples/mfs.rs index 97d1824..06a849e 100644 --- a/ipfs-api/examples/mfs.rs +++ b/ipfs-api/examples/mfs.rs @@ -49,42 +49,40 @@ fn main() { let file_rm = client.files_rm("/test", true); - let fut = - mkdir - .and_then(|_| { - println!("making dirs /test/does/not/exist/yet..."); - println!(); - - mkdir_recursive - }) - .and_then(|_| { - println!("getting status of /test/does..."); - println!(); - - file_stat - }) - .and_then(|stat| { - print_stat(stat); - - println!("writing source file to /test/mfs.rs"); - println!(); - - file_write - }) - .and_then(|_| file_write_stat) - .and_then(|stat| { - print_stat(stat); - - println!("removing /test..."); - println!(); - - file_rm - }) - .map(|_| println!("done!")) - .map_err(|e| eprintln!("{}", e)) - ; - - #[cfg(feature = "hyper")] + let fut = mkdir + .and_then(|_| { + println!("making dirs /test/does/not/exist/yet..."); + println!(); + + mkdir_recursive + }) + .and_then(|_| { + println!("getting status of /test/does..."); + println!(); + + file_stat + }) + .and_then(|stat| { + print_stat(stat); + + println!("writing source file to /test/mfs.rs"); + println!(); + + file_write + }) + .and_then(|_| file_write_stat) + .and_then(|stat| { + print_stat(stat); + + println!("removing /test..."); + println!(); + + file_rm + }) + .map(|_| println!("done!")) + .map_err(|e| eprintln!("{}", e)); + + #[cfg(feature = "hyper")] hyper::rt::run(fut); #[cfg(feature = "actix")] actix_web::actix::run(|| { diff --git a/ipfs-api/examples/ping_peer.rs b/ipfs-api/examples/ping_peer.rs index c60e895..af48f69 100644 --- a/ipfs-api/examples/ping_peer.rs +++ b/ipfs-api/examples/ping_peer.rs @@ -62,7 +62,7 @@ fn main() { }) .map_err(|e| eprintln!("{}", e)); - #[cfg(feature = "hyper")] + #[cfg(feature = "hyper")] hyper::rt::run(req); #[cfg(feature = "actix")] actix_web::actix::run(|| { |