Fixed infinite loop because of bracket

iand675 · Jul 10, 2024 · dc76362 · dc76362
1 parent aa493f2
commit dc76362
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/sdk/src/OpenTelemetry/LogRecordProcessor/Simple.hs b/sdk/src/OpenTelemetry/LogRecordProcessor/Simple.hs
@@ -23,7 +23,7 @@ simpleProcessor :: LogRecordExporter body -> IO (LogRecordProcessor body)
 simpleProcessor LogRecordExporter {..} = do
   (inChan :: InChan (LogRecord body), outChan :: OutChan (LogRecord body)) <- newChan
   exportWorker <- async $ forever $ do
-    bracket
+    bracketOnError
       (readChan outChan)
       (writeChan inChan)
       exportSingleLogRecord

diff --git a/sdk/test/OpenTelemetry/LogRecordProcessorSpec.hs b/sdk/test/OpenTelemetry/LogRecordProcessorSpec.hs
@@ -109,6 +109,7 @@ spec = describe "LogRecordProcessor" $ do
 
       numExports <- readIORef numExportsRef
       numExports `shouldBe` 3
+
       exportRes <- logRecordExporterExport testExporter H.empty
       exportRes `shouldSatisfy` \case
         Success -> False