diff --git a/CHANGELOG.md b/CHANGELOG.md index 921759e2fd1..89ab1f5389d 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -4,6 +4,10 @@ ⚠️ Important Notice: Starting from this release, we won’t be listing every dependency change in our changelog. This helps us maintain the project faster and focus on important features for our InfluxDB client. +### Bug Fixes + +1. [#794](https://github.com/influxdata/influxdb-client-java/issues/794): Delete unnecessary inheritance of `FlowableBufferTimedFlushable`. + ## 7.2.0 [2024-08-12] ### Features diff --git a/client/src/main/java/com/influxdb/client/internal/flowable/FlowableBufferTimedFlushable.java b/client/src/main/java/com/influxdb/client/internal/flowable/FlowableBufferTimedFlushable.java index c487d8980be..431f89cc770 100644 --- a/client/src/main/java/com/influxdb/client/internal/flowable/FlowableBufferTimedFlushable.java +++ b/client/src/main/java/com/influxdb/client/internal/flowable/FlowableBufferTimedFlushable.java @@ -35,8 +35,7 @@ * @param the output value type * @see FlowableBufferTimed */ -public final class FlowableBufferTimedFlushable> extends Flowable - implements FlowableTransformer { +public final class FlowableBufferTimedFlushable> extends Flowable { final Publisher source; final Publisher flusher; @@ -67,11 +66,6 @@ public FlowableBufferTimedFlushable(Publisher source, this.restartTimerOnMaxSize = true; } - @Override - public @NonNull Publisher apply(@NonNull final Flowable upstream) { - return new FlowableBufferTimedFlushable<>(upstream, flusher, timeskip, unit, maxSize, scheduler, bufferSupplier); - } - @Override protected void subscribeActual(@NonNull final Subscriber subscriber) { Scheduler.Worker w = scheduler.createWorker();