don't
fix(knot): spawn jetstream consumer tasks
Signed-off-by: tjh <x@tjh.dev>
+7
-1
+7
-1
crates/knot/src/services/jetstream.rs
+7
-1
crates/knot/src/services/jetstream.rs
···
60
60
}
61
61
62
62
let (jetstream, jetstream_rx, jetstream_rx_task) = config.connect();
63
+
let (consumer_result, jetstream_result) = tokio::join!(
64
+
tokio::spawn(consume(jetstream, knot, jetstream_rx)),
65
+
tokio::spawn(jetstream_rx_task)
66
+
);
63
67
64
-
tokio::join!(consume(jetstream, knot, jetstream_rx), jetstream_rx_task);
68
+
consumer_result?;
69
+
jetstream_result?;
70
+
65
71
Ok(())
66
72
}
67
73
}