diff --git a/crates/nu-command/Cargo.toml b/crates/nu-command/Cargo.toml index 7b83d4bd1f..12ec1695fe 100644 --- a/crates/nu-command/Cargo.toml +++ b/crates/nu-command/Cargo.toml @@ -62,7 +62,7 @@ itertools = "0.10.0" lazy_static = "1.*" log = "0.4.14" meval = "0.2.0" -minus = { optional = true, features = ["async_std_lib", "search"], git = "https://github.com/rezural/minus", branch = "add-finished-callback" } +minus = { optional = true, features = ["async_std_lib", "search"], git = "https://github.com/rezural/minus", branch = "nushell" } num-bigint = { version = "0.3.1", features = ["serde"] } num-format = { version = "0.4.0", features = ["with-num-bigint"] } num-traits = "0.2.14" diff --git a/crates/nu-command/src/commands/table/command.rs b/crates/nu-command/src/commands/table/command.rs index 27cea6f2d5..35657b9c02 100644 --- a/crates/nu-command/src/commands/table/command.rs +++ b/crates/nu-command/src/commands/table/command.rs @@ -210,13 +210,9 @@ async fn table( // This is called when the pager finishes, to indicate to the // while loop below to finish, in case of long running InputStream consumer // that doesnt finish by the time the user quits out of the pager - pager - .lock() - .await - .on_finished_callbacks - .push(Box::new(move || { - finished_within_callback.store(true, Ordering::Relaxed); - })); + pager.lock().await.add_exit_callback(move || { + finished_within_callback.store(true, Ordering::Relaxed); + }); } while !finished.clone().load(Ordering::Relaxed) { let mut new_input: VecDeque = VecDeque::new();