Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
In UnboundedSourceWrapper the lock scope is not big enough: we synchronise in emitElement() but should instead synchronise inside the reader loop in run() because the Source interface does not allow concurrent calls.