|
|
@ -112,7 +112,7 @@ public class JsonObjectEncoder extends AbstractEncoder<ByteBuffer> { |
|
|
|
buffer.flip(); |
|
|
|
buffer.flip(); |
|
|
|
|
|
|
|
|
|
|
|
BackpressureUtils.getAndSub(REQUESTED, this, 1L); |
|
|
|
BackpressureUtils.getAndSub(REQUESTED, this, 1L); |
|
|
|
downstream().onNext(buffer.byteBuffer()); |
|
|
|
subscriber.onNext(buffer.byteBuffer()); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
protected void drainLast(){ |
|
|
|
protected void drainLast(){ |
|
|
@ -123,7 +123,7 @@ public class JsonObjectEncoder extends AbstractEncoder<ByteBuffer> { |
|
|
|
buffer.append("]"); |
|
|
|
buffer.append("]"); |
|
|
|
} |
|
|
|
} |
|
|
|
buffer.flip(); |
|
|
|
buffer.flip(); |
|
|
|
downstream().onNext(buffer.byteBuffer()); |
|
|
|
subscriber.onNext(buffer.byteBuffer()); |
|
|
|
super.doComplete(); |
|
|
|
super.doComplete(); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|