Merge pull request #6991 from blockscout/fix-buffered-task-initial-stream

Fix BufferedTask initial stream

CHANGELOG.md

@@ -25,7 +25,7 @@
 - [#6973](https://github.com/blockscout/blockscout/pull/6973) - API v2: `/smart-contracts` and `/state-changes` endpoints
 - [#6897](https://github.com/blockscout/blockscout/pull/6897) - Support basic auth in JSON RPC endpoint
 - [#6908](https://github.com/blockscout/blockscout/pull/6908) - Allow disable API rate limit
-- [#6951](https://github.com/blockscout/blockscout/pull/6951), [#6958](https://github.com/blockscout/blockscout/pull/6958) - Set poll: true for TokenInstance fetcher
+- [#6951](https://github.com/blockscout/blockscout/pull/6951), [#6958](https://github.com/blockscout/blockscout/pull/6958), [#6991](https://github.com/blockscout/blockscout/pull/6991) - Set poll: true for TokenInstance fetcher
 - [#5720](https://github.com/blockscout/blockscout/pull/5720) - Fetchers graceful shutdown
 
 ### Fixes

apps/indexer/lib/indexer/buffered_task.ex

@@ -341,6 +341,10 @@ defmodule Indexer.BufferedTask do
     %{state | current_buffer: [entries | state.current_buffer]}
   end
 
+  defp do_initial_stream(%BufferedTask{init_task: init_task} = state) when is_reference(init_task) do
+    schedule_next_buffer_flush(state)
+  end
+
   defp do_initial_stream(
          %BufferedTask{
            callback_module: callback_module,