Newer version of hysterical-streams.

cabal.project

@@ -304,4 +304,4 @@ source-repository-package
 source-repository-package
   type: git
   location: https://github.com/raduom/hysterical-screams
-  tag: 211c478343eb7cf3651af22fb550c3b3f0d80bc7
+  tag: ab9e9c778fc2a61d8bfdb78922e2f38e09d2f4cc

nix/pkgs/haskell/sha256map.nix

@@ -16,5 +16,5 @@
   "https://github.com/input-output-hk/servant-purescript"."44e7cacf109f84984cd99cd3faf185d161826963" = "10pb0yfp80jhb9ryn65a4rha2lxzsn2vlhcc6xphrrkf4x5lhzqc";
   "https://github.com/input-output-hk/Win32-network"."3825d3abf75f83f406c1f7161883c438dac7277d" = "19wahfv726fa3mqajpqdqhnl9ica3xmf68i254q45iyjcpj1psqx";
   "https://github.com/Quid2/flat"."ee59880f47ab835dbd73bea0847dab7869fc20d8" = "1lrzknw765pz2j97nvv9ip3l1mcpf2zr4n56hwlz0rk7wq7ls4cm";
-  "https://github.com/raduom/hysterical-screams"."211c478343eb7cf3651af22fb550c3b3f0d80bc7" = "0m4gac3xpa8rsqib851grgp3cch494vqnxz8qzzyh8lzilvgni21";
+  "https://github.com/raduom/hysterical-screams"."ab9e9c778fc2a61d8bfdb78922e2f38e09d2f4cc" = "02m28w7h8h6jqv5w71arg07dsgh0gml8qckrhkn8vysbcr4g93dy";
 }

plutus-streaming/src/Index/TxIdStatus.hs

@@ -10,6 +10,8 @@ import Data.Map (Map)
 import Data.Map qualified as Map
 import Data.Maybe (catMaybes, fromJust)
 import Data.Monoid (Last (Last), Sum (Sum, getSum))
+import Data.Sequence (Seq)
+import Data.Sequence qualified as Seq
 import Database.SQLite.Simple (execute, execute_)
 import Index.Split (SplitIndex (SplitIndex, siBuffered, siHandle))
 import Index.Sqlite (SqliteIndex)
@@ -26,7 +28,7 @@ type TxStatusIndex = SqliteIndex SimpleChainSyncEvent () TxId TxConfirmedState
 
 openIx :: FilePath -> IO TxStatusIndex
 openIx path =
-  fromJust <$> Ix.new query onInsert store 3000 path
+  fromJust <$> Ix.new query onInsert store 2000 path
 
 -- Ignore notifications for now
 onInsert :: SimpleChainSyncEvent -> TxStatusIndex -> IO [()]

shell.nix

@@ -1,5 +1,5 @@
 { system ? builtins.currentSystem
-, enableHaskellProfiling ? false
+, enableHaskellProfiling ? true
 , sourcesOverride ? { }
 , sources ? import ./nix/sources.nix { inherit system; } // sourcesOverride
 , packages ? import ./. { inherit system enableHaskellProfiling sources sourcesOverride; }