Merge pull request #56 from yukihirop/fix/panic

Fix/panic

CHANGELOG.md

@@ -1,5 +1,9 @@
 # CHANGELOG
 
+## v0.3.2
+
+- fix #55
+
 ## v0.3.1
 
 - [Breaking] fix `port_for` logic.

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ultraman"
-version = "0.3.1"
+version = "0.3.2"
 authors = ["yukihirop <te108186@gmail.com>"]
 repository = "https://github.com/yukihirop/ultraman"
 edition = "2018"

docs/DEVELOP.md

@@ -0,0 +1,16 @@
+# Development
+
+## Example
+
+```bash
+cd example/start
+cargo run start -p ./Procfile
+```
+
+## Release
+
+```bash
+cargo build
+cargo bump
+cargo publish --dry-run
+```

example/start/Procfile

@@ -2,3 +2,5 @@ exit_0: ./fixtures/exit_0.sh
 exit_1: ./fixtures/exit_1.sh
 loop: ./fixtures/loop.sh $MESSAGE
 web: bundle exec puma -p $PORT -C ./config/puma.rb
+early_out: seq 100
+sleep: sleep 20

src/process.rs

@@ -36,7 +36,10 @@ impl Process {
             String::from("PORT"),
             port_for(&env_path, port, concurrency_index).to_string(),
         );
-        read_env.insert(String::from("PS"), ps_for(process_name, concurrency_index + 1));
+        read_env.insert(
+            String::from("PS"),
+            ps_for(process_name, concurrency_index + 1),
+        );
         let shell = os_env::var("SHELL").expect("$SHELL is not set");
 
         Process {

src/stream_read.rs

@@ -37,11 +37,17 @@ impl PipeStreamReader {
                             }
                             Ok(_) => {
                                 if byte[0] == 0x0A {
-                                    tx.send(match String::from_utf8(buf.clone()) {
+                                    match tx.send(match String::from_utf8(buf.clone()) {
                                         Ok(line) => Ok(PipedLine::Line(line)),
                                         Err(err) => Err(PipeError::NotUtf8(err)),
-                                    })
-                                    .unwrap();
+                                    }) {
+                                        Ok(_) => {}
+                                        Err(e) => {
+                                            println!("Failed to send message: {}", e);
+                                            break;
+                                        }
+                                    }
+
                                     buf.clear()
                                 } else {
                                     buf.push(byte[0])