|
1 | | -use std::any::{Any, TypeId}; |
2 | | -use std::borrow::Cow; |
| 1 | +use std::any::Any; |
3 | 2 | use std::path::PathBuf; |
4 | 3 | use std::pin::Pin; |
5 | | -use std::{collections::HashMap, fmt::Display, fmt::Write, sync::Arc}; |
| 4 | +use std::{collections::HashMap, fmt::Display, sync::Arc}; |
6 | 5 |
|
7 | 6 | use crate::modules::{CommandRunner, InputEvent, InputRx, InputTx, Tap}; |
8 | | -use crate::{modules::SharedInputFut, util::FutureExt as _}; |
9 | | -use futures_util::future::{Join, join_all}; |
10 | | -use futures_util::{Stream, stream}; |
| 7 | +use futures_util::Stream; |
11 | 8 | use indexmap::IndexMap; |
12 | 9 | use serde::{Deserialize, Serialize}; |
13 | | -use tokio::sync::broadcast::error::SendError; |
14 | 10 | use tokio::sync::{Mutex, broadcast}; |
15 | 11 | use tokio::task::JoinHandle; |
16 | 12 |
|
17 | 13 | use crate::{ |
18 | | - modules::{Context, Input, InputFut}, |
| 14 | + modules::{Context, Input}, |
19 | 15 | ts::MODULES, |
20 | 16 | }; |
21 | 17 |
|
@@ -357,7 +353,6 @@ impl Pipe { |
357 | 353 | .get(key) |
358 | 354 | .map(|x| &**x as &(dyn Any + Send + Sync)) |
359 | 355 | .and_then(|x| { |
360 | | - println!("Command TypeId: {:?}", x.type_id()); |
361 | 356 | x.downcast_ref::<T>() |
362 | 357 | }) |
363 | 358 | } |
|
0 commit comments