summaryrefslogtreecommitdiffstats
path: root/examples
diff options
context:
space:
mode:
Diffstat (limited to 'examples')
-rw-r--r--examples/containerexec.rs9
-rw-r--r--examples/logs.rs9
2 files changed, 10 insertions, 8 deletions
diff --git a/examples/containerexec.rs b/examples/containerexec.rs
index 0b3575b..0bfd640 100644
--- a/examples/containerexec.rs
+++ b/examples/containerexec.rs
@@ -25,10 +25,11 @@ fn main() {
.containers()
.get(&id)
.exec(&options)
- .for_each(|line| {
- match line.stream_type {
- StreamType::StdOut => println!("Stdout: {}", line.data),
- StreamType::StdErr => eprintln!("Stderr: {}", line.data),
+ .for_each(|chunk| {
+ match chunk.stream_type {
+ StreamType::StdOut => println!("Stdout: {}", chunk.as_string_lossy()),
+ StreamType::StdErr => eprintln!("Stderr: {}", chunk.as_string_lossy()),
+ StreamType::StdIn => unreachable!(),
}
Ok(())
})
diff --git a/examples/logs.rs b/examples/logs.rs
index b35b0a3..6fad7d6 100644
--- a/examples/logs.rs
+++ b/examples/logs.rs
@@ -14,10 +14,11 @@ fn main() {
.containers()
.get(&id)
.logs(&LogsOptions::builder().stdout(true).stderr(true).build())
- .for_each(|line| {
- match line.stream_type {
- StreamType::StdOut => println!("Stdout: {}", line.data),
- StreamType::StdErr => eprintln!("Stderr: {}", line.data),
+ .for_each(|chunk| {
+ match chunk.stream_type {
+ StreamType::StdOut => println!("Stdout: {}", chunk.as_string_lossy()),
+ StreamType::StdErr => eprintln!("Stderr: {}", chunk.as_string_lossy()),
+ StreamType::StdIn => unreachable!(),
}
Ok(())
})