Add tests for crashing neovim with linebuffering

Cargo.toml

@@ -112,3 +112,15 @@ required-features = ["use_tokio"]
 
 [[test]]
 name = "basic"
+
+[[test]]
+name = "regression"
+path = "tests/regression/mod.rs"
+
+[[bin]]
+name = "linebuffercrash"
+required-features = ["use_tokio"]
+
+[[bin]]
+name = "linebuffercrash_as"
+required-features = ["use_async-std"]

src/bin/linebuffercrash.rs

@@ -0,0 +1,24 @@
+
+use nvim_rs::{
+  create::tokio as create, 
+  rpc::handler::Dummy as DummyHandler
+};
+
+
+#[tokio::main]
+async fn main() {
+  let handler = DummyHandler::new();
+  let (nvim, _io_handler) = create::new_parent(handler).await.unwrap();
+  let curbuf = nvim.get_current_buf().await.unwrap();
+
+    // If our Stdout is linebuffered, this has a high chance of crashing neovim
+    // Should probably befixed in neovim itself, but for now, let's just make
+    // sure we're not using linebuffering, or at least don't crash neovim with
+    // this.
+    for i in 0..20 { 
+        curbuf.set_name(&format!("a{i}")).await.unwrap();
+    }
+
+    let _ = nvim.command("quit!").await;
+
+}

src/bin/linebuffercrash_as.rs

@@ -0,0 +1,24 @@
+
+use nvim_rs::{
+  create::async_std as create, 
+  rpc::handler::Dummy as DummyHandler
+};
+
+
+#[async_std::main]
+async fn main() {
+  let handler = DummyHandler::new();
+  let (nvim, _io_handler) = create::new_parent(handler).await.unwrap();
+  let curbuf = nvim.get_current_buf().await.unwrap();
+
+    // If our Stdout is linebuffered, this has a high chance of crashing neovim
+    // Should probably befixed in neovim itself, but for now, let's just make
+    // sure we're not using linebuffering, or at least don't crash neovim with
+    // this.
+    for i in 0..20 { 
+        curbuf.set_name(&format!("a{i}")).await.unwrap();
+    }
+
+    let _ = nvim.command("quit!").await;
+
+}

tests/regression/buffering.rs

@@ -0,0 +1,45 @@
+#[path = "../common/mod.rs"]
+mod common;
+use common::*;
+
+use std::{path::PathBuf, process::Command};
+
+fn viml_escape(in_str: &str) -> String {
+  in_str.replace('\\', r"\\")
+}
+
+fn linebuffercrashbin() -> &'static str {
+  #[cfg(feature = "use_tokio")]
+  return "linebuffercrash";
+  #[cfg(feature = "use_async-std")]
+  return "linebuffercrash_as";
+}
+
+#[test]
+fn linebuffer_crash() {
+  let c1 = format!(
+    "let jobid = jobstart([\"{}\"], {{\"rpc\": v:true}})",
+    viml_escape(
+      PathBuf::from(env!("CARGO_MANIFEST_DIR"))
+        .join("target")
+        .join("debug")
+        .join(linebuffercrashbin())
+        .to_str()
+        .unwrap()
+    )
+  );
+
+  let status = Command::new(nvim_path())
+    .args(&[
+      "-u",
+      "NONE",
+      "--headless",
+      "-c",
+      &c1,
+    ])
+    .status()
+    .unwrap();
+
+  assert!(status.success());
+
+}

tests/regression/mod.rs

@@ -0,0 +1,4 @@
+#[cfg(feature = "use_tokio")]
+pub mod buffering;
+#[cfg(feature = "use_async-std")]
+pub mod buffering;