diff --git a/src/main.rs b/src/main.rs index 3c99126..fa2f8ed 100644 --- a/src/main.rs +++ b/src/main.rs @@ -57,7 +57,7 @@ async fn main() -> anyhow::Result<()> { // This message passing channel is used for sending messages to the matrix module, // it holds a tuple with an HTML message and a list of rooms to post to - let (bcast_tx, bcast_rx) = broadcast::channel(1024); + let (bcast_tx, bcast_rx) = broadcast::channel::<(String, Vec)>(1024); let handles: Vec> = config.feeds.clone().into_iter().map(|feed_config| { let state_db = Arc::clone(&state_db); @@ -131,7 +131,7 @@ async fn main() -> anyhow::Result<()> { }) }).collect(); - login_and_sync::<(String, Vec)>( + login_and_sync( config.homeserver_uri.clone().into(), &config.username, &config.password, diff --git a/src/matrix.rs b/src/matrix.rs index 61b10fc..966a536 100644 --- a/src/matrix.rs +++ b/src/matrix.rs @@ -85,7 +85,7 @@ async fn send_to_room( }; } -pub async fn login_and_sync( +pub async fn login_and_sync( homeserver_url: String, username: &str, password: &str,