Skip to content

Commit 3d41c0a

Browse files
committed
chore: remove flushCommands and setAutoFlushCommands and it's implementations from async commands API
Signed-off-by: The-East-Wind <[email protected]>
1 parent 51dba83 commit 3d41c0a

File tree

2 files changed

+0
-32
lines changed

2 files changed

+0
-32
lines changed

src/main/java/io/lettuce/core/AbstractRedisAsyncCommands.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1075,11 +1075,6 @@ public RedisFuture<List<Map<String, Object>>> functionList(String libraryName) {
10751075
return dispatch(commandBuilder.functionList(libraryName));
10761076
}
10771077

1078-
@Override
1079-
public void flushCommands() {
1080-
connection.flushCommands();
1081-
}
1082-
10831078
@Override
10841079
public RedisFuture<String> flushall() {
10851080
return dispatch(commandBuilder.flushall());
@@ -2350,11 +2345,6 @@ public RedisFuture<V> setGet(K key, V value, SetArgs setArgs) {
23502345
return dispatch(commandBuilder.setGet(key, value, setArgs));
23512346
}
23522347

2353-
@Override
2354-
public void setAutoFlushCommands(boolean autoFlush) {
2355-
connection.setAutoFlushCommands(autoFlush);
2356-
}
2357-
23582348
@Override
23592349
public void setTimeout(Duration timeout) {
23602350
connection.setTimeout(timeout);

src/main/java/io/lettuce/core/api/async/BaseRedisAsyncCommands.java

Lines changed: 0 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -206,26 +206,4 @@ public interface BaseRedisAsyncCommands<K, V> {
206206
@Deprecated
207207
void reset();
208208

209-
/**
210-
* Disable or enable auto-flush behavior. Default is {@code true}. If autoFlushCommands is disabled, multiple commands can
211-
* be issued without writing them actually to the transport. Commands are buffered until a {@link #flushCommands()} is
212-
* issued. After calling {@link #flushCommands()} commands are sent to the transport and executed by Redis.
213-
*
214-
* @param autoFlush state of autoFlush.
215-
* @deprecated since 6.2. Use the corresponding {@link io.lettuce.core.api.StatefulConnection#setAutoFlushCommands(boolean)}
216-
* method on the connection interface. To be removed with Lettuce 7.0.
217-
*/
218-
@Deprecated
219-
void setAutoFlushCommands(boolean autoFlush);
220-
221-
/**
222-
* Flush pending commands. This commands forces a flush on the channel and can be used to buffer ("pipeline") commands to
223-
* achieve batching. No-op if channel is not connected.
224-
*
225-
* @deprecated since 6.2. Use the corresponding {@link io.lettuce.core.api.StatefulConnection#flushCommands()} method on the
226-
* connection interface. To be removed with Lettuce 7.0.
227-
*/
228-
@Deprecated
229-
void flushCommands();
230-
231209
}

0 commit comments

Comments
 (0)