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();