fix: place command status left of battery as a separate segment

tests/unit/session.rs

@@ -4,6 +4,65 @@ use std::{
     sync::atomic::{AtomicU64, Ordering},
 };
 
+#[cfg(unix)]
+#[test]
+fn concurrent_shell_commands_share_status_and_queue_every_completed_output() {
+    let fixture = Fixture::new();
+    fixture.file("buffer.txt", "source");
+    let mut session = fixture.open("");
+    session.editor.set_project_root(fixture.0.clone());
+    session.execute("!printf FIRST; while [ ! -f first ]; do sleep 0.01; done");
+    session.execute("!echo SECOND; while [ ! -f second ]; do sleep 0.01; done; exit 9");
+    assert_eq!(session.shell.len(), 2);
+    let fixed = Instant::now();
+    for running in &mut session.shell {
+        running.started = fixed;
+    }
+    session.poll_shell_at(fixed + Duration::from_millis(199));
+    assert_eq!(session.editor.shell_label(), "");
+    session.poll_shell_at(fixed + Duration::from_millis(200));
+    assert_eq!(session.editor.shell_label(), "pri... -  ech... -");
+    fixture.file("second", "");
+    drain_until(&mut session, |session| session.shell.len() == 1);
+    assert_eq!(
+        session.editor.command_output().unwrap().content.lines[0],
+        "SECOND"
+    );
+    assert!(
+        session
+            .editor
+            .command_output()
+            .unwrap()
+            .title
+            .contains("exit 9")
+    );
+    assert!(session.editor.shell_label().starts_with("pri... "));
+    assert!(!session.editor.shell_label().contains("ech..."));
+    fixture.file("first", "");
+    drain_until(&mut session, |session| session.shell.is_empty());
+    assert_eq!(session.editor.shell_label(), "");
+    assert_eq!(
+        session.editor.command_output().unwrap().content.lines[0],
+        "SECOND"
+    );
+    session.handle(Input::Enter);
+    assert_eq!(
+        session.editor.command_output().unwrap().content.lines,
+        ["FIRST"]
+    );
+    assert!(
+        session
+            .editor
+            .command_output()
+            .unwrap()
+            .title
+            .contains("exit 0")
+    );
+    session.handle(Input::Escape);
+    assert!(session.editor.command_output().is_none());
+    assert_eq!(session.editor.lines(), ["source"]);
+}
+
 #[cfg(unix)]
 #[test]
 fn shell_commands_leave_editing_live_and_present_both_streams_and_exit_status() {
@@ -19,17 +78,11 @@ fn shell_commands_leave_editing_live_and_present_both_streams_and_exit_status()
     }
     session.handle(Input::Enter);
     let fixed = Instant::now();
-    session.shell.as_mut().unwrap().2 = fixed;
+    session.shell[0].started = fixed;
     assert!(!session.poll_shell_at(fixed + Duration::from_millis(199)));
     assert_eq!(session.editor.shell_label(), "");
     assert!(session.poll_shell_at(fixed + Duration::from_millis(200)));
     assert_eq!(session.editor.shell_label(), "whi... -");
-    session.execute("!printf should-not-run > unexpected");
-    assert_eq!(
-        session.editor.message(),
-        "A shell command is already running"
-    );
-    assert!(!fixture.0.join("unexpected").exists());
     session.handle(Input::Char('i'));
     session.handle(Input::Char('X'));
     assert_eq!(session.editor.lines(), ["Xsource"]);
@@ -63,7 +116,7 @@ fn shell_commands_reject_empty_input_and_show_empty_success_without_editing() {
     let mut session = fixture.open("");
     session.execute(":!");
     assert_eq!(session.editor.message(), "Shell command is empty");
-    assert!(session.shell.is_none());
+    assert!(session.shell.is_empty());
     session.execute(":!true");
     drain_until(&mut session, |session| {
         session.editor.command_output().is_some()