diff --git a/services/scribe/grpc/server/server.go b/services/scribe/grpc/server/server.go index 73952d2f3c..f6a8d3a258 100644 --- a/services/scribe/grpc/server/server.go +++ b/services/scribe/grpc/server/server.go @@ -158,7 +158,7 @@ func (s *server) StreamLogs(req *pbscribe.StreamLogsRequest, res pbscribe.Scribe if latestScribeBlock > toBlock { nextFromBlock = toBlock + 1 - toBlock = latestScribeBlock - 1 + toBlock = latestScribeBlock wait = 0 span.AddEvent("New block. From: " + strconv.Itoa(int(nextFromBlock)) + " To: " + strconv.Itoa(int(toBlock)))