Skip to content

Commit

Permalink
Remove thing that will not fix anything
Browse files Browse the repository at this point in the history
  • Loading branch information
svroonland committed Nov 9, 2024
1 parent 566b0f3 commit 1485d1d
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -580,7 +580,7 @@ private[consumer] final class Runloop private (
)
}
} yield pollresult
}.uninterruptible // Make sure that calls to the consumer are completed, so that its single-thread access protection locks are released
}
fulfillResult <- offerRecordsToStreams(
pollResult.assignedStreams,
pollResult.pendingRequests,
Expand Down

0 comments on commit 1485d1d

Please sign in to comment.