[BUG] added backpressure buffer after PublishSubject
@@ -85,7 +85,7 @@ public class GDMModelReceiver implements ObjectReceiver<GDMModel> {
public Observable<GDMModel> getObservable() {
- return modelSubject.lift(new BufferOperator()).filter(m -> {
+ return modelSubject.onBackpressureBuffer().lift(new BufferOperator()).filter(m -> {
if (!afterClosedStream.get() && !gdmModelDeque.isEmpty()) {
