we dont have catchup so just comment it out
parent
f0e5dc7428
commit
aefb726109
|
@ -134,13 +134,13 @@ async fn run_subscription(
|
||||||
|
|
||||||
tracing::debug!(id = %sub.id, "subscription started");
|
tracing::debug!(id = %sub.id, "subscription started");
|
||||||
|
|
||||||
if let Some(_cursor) = cursor {
|
/* if let Some(cursor) = cursor {
|
||||||
tracing::debug!(id = %sub.id, "filling from event cache");
|
tracing::debug!(id = %sub.id, "subscription filling from cache");
|
||||||
|
|
||||||
// TODO: cursor catchup (read from server db history)
|
// TODO: cursor catchup (read from server db history)
|
||||||
|
|
||||||
tracing::debug!(id = %sub.id, "subscription live-tailing");
|
tracing::debug!(id = %sub.id, "subscription live-tailing");
|
||||||
}
|
} */
|
||||||
|
|
||||||
// live tailing:
|
// live tailing:
|
||||||
let mut raw_block_rx = server.raw_block_tx.subscribe();
|
let mut raw_block_rx = server.raw_block_tx.subscribe();
|
||||||
|
|
Loading…
Reference in New Issue