From 289aee3ed0fa30fbff92bae9838c2c7791706473 Mon Sep 17 00:00:00 2001
From: Daniel Zhang <orezsilence@163.com>
Date: Wed, 25 Dec 2024 17:53:38 +0800
Subject: [PATCH] refactor:Delete unnecessary inheritance of
 FlowableBufferTimedFlushable

---
 .../internal/flowable/FlowableBufferTimedFlushable.java   | 8 +-------
 1 file changed, 1 insertion(+), 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
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 <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();