Skip to content

Commit

Permalink
cherry pick: 5c9627d
Browse files Browse the repository at this point in the history
  • Loading branch information
alexanderbez committed Dec 19, 2023
1 parent dddb8b4 commit 3ef76da
Showing 1 changed file with 6 additions and 8 deletions.
14 changes: 6 additions & 8 deletions baseapp/chain_stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,13 +11,11 @@ type StreamEvents struct {
}

func (app *BaseApp) AddStreamEvents(height int64, events []abci.Event, flush bool) {
go func() {
if app.EnableStreamer {
app.StreamEvents <- StreamEvents{
Events: events,
Height: uint64(height),
Flush: flush,
}
if app.EnableStreamer {
app.StreamEvents <- StreamEvents{
Events: events,
Height: uint64(height),
Flush: flush,
}
}()
}
}

0 comments on commit 3ef76da

Please sign in to comment.