From 4616938525a8385f3c7da786f37867c0854e9a8a Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Tue, 8 Dec 2015 13:21:35 +0000 Subject: [PATCH] Prepare for a future change to downstream() inner method in reactor-core --- .../springframework/core/codec/support/JsonObjectEncoder.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-web-reactive/src/main/java/org/springframework/core/codec/support/JsonObjectEncoder.java b/spring-web-reactive/src/main/java/org/springframework/core/codec/support/JsonObjectEncoder.java index d3079ebe2f..ffe5a85d8c 100644 --- a/spring-web-reactive/src/main/java/org/springframework/core/codec/support/JsonObjectEncoder.java +++ b/spring-web-reactive/src/main/java/org/springframework/core/codec/support/JsonObjectEncoder.java @@ -112,7 +112,7 @@ public class JsonObjectEncoder extends AbstractEncoder { buffer.flip(); BackpressureUtils.getAndSub(REQUESTED, this, 1L); - downstream().onNext(buffer.byteBuffer()); + subscriber.onNext(buffer.byteBuffer()); } protected void drainLast(){ @@ -123,7 +123,7 @@ public class JsonObjectEncoder extends AbstractEncoder { buffer.append("]"); } buffer.flip(); - downstream().onNext(buffer.byteBuffer()); + subscriber.onNext(buffer.byteBuffer()); super.doComplete(); } }