Use a type annotation in the event bus test rather than the turbofish…

… annotation
OscartGiles · Jul 30, 2024 · d40e478 · d40e478
1 parent 6cce39a
commit d40e478
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/rivelin_actors/tests/event_bus.rs b/rivelin_actors/tests/event_bus.rs
@@ -1,7 +1,7 @@
 use std::time::Duration;
 
 use futures_util::StreamExt;
-use rivelin_actors::event_bus::{EventBus, EventBusAddr, EventSinkState, Filter, Topic};
+use rivelin_actors::event_bus::{Consumer, EventBus, EventBusAddr, EventSinkState, Filter, Topic};
 use rivelin_actors::Actor;
 
 #[tokio::test]
@@ -15,9 +15,7 @@ async fn event_bus_string() -> anyhow::Result<()> {
         type MessageType = String;
     }
 
-    let mut consumer = addr
-        .consumer::<HelloTopic, _>(Filter::all_subtopics)
-        .await?;
+    let mut consumer: Consumer<HelloTopic> = addr.consumer(Filter::all_subtopics).await?;
 
     let producer = addr.producer(HelloTopic);
     producer