Commit 11c6a4a

committed

improves UnboundedProcessor impl to ensure no leaks and deadlocks

Signed-off-by: Oleh Dokuka <shadowgun@i.ua>

1 parent e11a53b commit 11c6a4aCopy full SHA for 11c6a4a

2 files changed

+204

-69

lines changed

rsocket-core/src
- main/java/io/rsocket/internal
  - UnboundedProcessor.java
- test/java/io/rsocket/internal
  - UnboundedProcessorTest.java

+204

-69

lines changed

Comments

(0)