github/wasm-pong
1
0
Fork 0
mirror of https://github.com/thilo-behnke/wasm-pong.git synced 2026-07-11 02:29:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

progress?

Browse Source
This commit is contained in:
Thilo Behnke
2022-07-10 13:23:25 +02:00
parent a86d0cebfa
commit 8f65d83d15
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pong/src/event.rs
View File

@@ -13,7 +13,7 @@ pub mod event {
}
#[async_trait]
pub trait EventWriterImpl {
pub trait EventWriterImpl : Send {
async fn write(&mut self, events: Vec<EventWrapper>) -> Result<(), String>;
}
@@ -82,7 +82,7 @@ pub mod event {
}
#[async_trait]
pub trait EventReaderImpl {
pub trait EventReaderImpl : Send {
async fn read(&mut self) -> Result<Vec<EventWrapper>, String>;
}

4
server/src/session_manager.rs
View File

@@ -215,7 +215,7 @@ impl SessionManager {
return Ok((reader.unwrap(), writer.unwrap()));
}
pub fn get_session_reader(
pub async fn get_session_reader(
&self,
session_id: &str,
topics: &[&str],
@@ -225,7 +225,7 @@ impl SessionManager {
return Err(format!("Unable to find session with hash {}", session_id));
}
let session = session.unwrap();
let kafka_reader = KafkaSessionEventReaderImpl::new(&self.kafka_host, &session, topics);
let kafka_reader = KafkaSessionEventReaderImpl::new(&self.kafka_host, &session, topics).await;
if let Err(_) = kafka_reader {
return Err("Unable to create kafka reader.".to_string());
}