chore: add missing parameter
This commit is contained in:
parent
cc6b58f73d
commit
9bd6589aa8
|
|
@ -1,6 +1,8 @@
|
|||
use anyhow::Context;
|
||||
use collab_stream::client::CollabRedisStream;
|
||||
use collab_stream::metrics::CollabStreamMetrics;
|
||||
use rand::{thread_rng, Rng};
|
||||
use std::sync::Arc;
|
||||
|
||||
pub async fn redis_client() -> redis::Client {
|
||||
let redis_uri = "redis://localhost:6379";
|
||||
|
|
@ -11,7 +13,7 @@ pub async fn redis_client() -> redis::Client {
|
|||
|
||||
pub async fn stream_client() -> CollabRedisStream {
|
||||
let redis_client = redis_client().await;
|
||||
CollabRedisStream::new(redis_client)
|
||||
CollabRedisStream::new(redis_client, Arc::new(CollabStreamMetrics::default()))
|
||||
.await
|
||||
.context("failed to create stream client")
|
||||
.unwrap()
|
||||
|
|
|
|||
Loading…
Reference in New Issue