refactor:Delete unnecessary inheritance of FlowableBufferTimedFlushable

influxdata · Dec 25, 2024 · 289aee3 · 289aee3
1 parent f9283d6
commit 289aee3
Showing 1 changed file with 1 addition and 7 deletions.
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
@@ -35,8 +35,7 @@
  * @param <U> the output value type
  * @see FlowableBufferTimed
  */
-public final class FlowableBufferTimedFlushable<T, U extends List<? super T>> extends Flowable<U>
-        implements FlowableTransformer<T, U> {
+public final class FlowableBufferTimedFlushable<T, U extends List<? super T>> extends Flowable<U> {
 
     final Publisher<T> source;
     final Publisher<Boolean> flusher;
@@ -67,11 +66,6 @@ public FlowableBufferTimedFlushable(Publisher<T> source,
         this.restartTimerOnMaxSize = true;
     }
 
-    @Override
-    public @NonNull Publisher<U> apply(@NonNull final Flowable<T> upstream) {
-        return new FlowableBufferTimedFlushable<>(upstream, flusher, timeskip, unit, maxSize, scheduler, bufferSupplier);
-    }
-
     @Override
     protected void subscribeActual(@NonNull final Subscriber<? super U> subscriber) {
         Scheduler.Worker w = scheduler.createWorker();