Skip to content

Commit 2e84405

Browse files
committed
improves error propagation in sync pipe cancellation
Signed-off-by: Oleh Dokuka <shadowgun@i.ua>
1 parent 82241f3 commit 2e84405

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

rsocket-core/src/main/java/io/rsocket/core/RequestChannelResponderSubscriber.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -288,6 +288,7 @@ public void request(long n) {
288288
public void cancel() {
289289
long previousState = markInboundTerminated(STATE, this);
290290
if (isTerminated(previousState) || isInboundTerminated(previousState)) {
291+
INBOUND_ERROR.lazySet(this, TERMINATED);
291292
return;
292293
}
293294

0 commit comments

Comments
 (0)