Skip BatchFuture (#217)

shenkeyao · web-flow · commit 32711a2f1beb · 2025-08-29T10:29:14.000-07:00
diff --git a/espresso/streamer.go b/espresso/streamer.go
@@ -348,6 +348,7 @@ func (s *EspressoStreamer[B]) processRemainingBatches(ctx context.Context) {
 		case BatchFuture:
 			// The function CheckBatch is not expected to return BatchFuture so if we enter this case there is a problem.
 			s.Log.Error("Remaining list", "BatchFuture validity not expected for batch", batch)
+			continue
 		}
 
 		s.Log.Trace("Remaining list", "Inserting batch into buffer", "batch", batch)
@@ -397,6 +398,7 @@ func (s *EspressoStreamer[B]) processEspressoTransactions(ctx context.Context, i
 		case BatchFuture:
 			// The function CheckBatch is not expected to return BatchFuture so if we enter this case there is a problem.
 			s.Log.Error("Remaining list", "BatchFuture validity not expected for batch", batch)
+			continue
 		}
 
 		s.Log.Trace("Inserting batch into buffer", "batch", batch)

Original file line number	Diff line number	Diff line change
`@@ -348,6 +348,7 @@ func (s *EspressoStreamer[B]) processRemainingBatches(ctx context.Context) {`
`348`	`348`	`case BatchFuture:`
`349`	`349`	`// The function CheckBatch is not expected to return BatchFuture so if we enter this case there is a problem.`
`350`	`350`	`s.Log.Error("Remaining list", "BatchFuture validity not expected for batch", batch)`
	`351`	`+ continue`
`351`	`352`	`}`
`352`	`353`
`353`	`354`	`s.Log.Trace("Remaining list", "Inserting batch into buffer", "batch", batch)`
`@@ -397,6 +398,7 @@ func (s *EspressoStreamer[B]) processEspressoTransactions(ctx context.Context, i`
`397`	`398`	`case BatchFuture:`
`398`	`399`	`// The function CheckBatch is not expected to return BatchFuture so if we enter this case there is a problem.`
`399`	`400`	`s.Log.Error("Remaining list", "BatchFuture validity not expected for batch", batch)`
	`401`	`+ continue`
`400`	`402`	`}`
`401`	`403`
`402`	`404`	`s.Log.Trace("Inserting batch into buffer", "batch", batch)`