RStream deprecated methods removed

pull/5644/head
Nikita Koksharov
parent 4cff7f45d2
commit 62097d0ea2

@ -48,27 +48,6 @@ public interface StreamAddArgs<K, V> {
*/ */
StreamTrimStrategyArgs<StreamAddArgs<K, V>> trimNonStrict(); StreamTrimStrategyArgs<StreamAddArgs<K, V>> trimNonStrict();
/*
* Use trimNonStrict() method instead
*
*/
@Deprecated
StreamAddArgs<K, V> trim(TrimStrategy strategy, int threshold);
/*
* Use trimNonStrict() method instead
*
*/
@Deprecated
StreamAddArgs<K, V> trim(TrimStrategy strategy, int threshold, int limit);
/*
* Use trim() method instead
*
*/
@Deprecated
StreamAddArgs<K, V> trimStrict(TrimStrategy strategy, int threshold);
/** /**
* Defines entry to add * Defines entry to add
* *

@ -46,26 +46,6 @@ public final class StreamAddParams<K, V> implements StreamAddArgs<K, V>,
return this; return this;
} }
@Override
public StreamAddArgs<K, V> trim(TrimStrategy strategy, int threshold) {
return trim(strategy, threshold, 0);
}
@Override
public StreamAddArgs<K, V> trimStrict(TrimStrategy strategy, int threshold) {
this.maxLen = threshold;
this.trimStrict = true;
return this;
}
@Override
public StreamAddArgs<K, V> trim(TrimStrategy strategy, int threshold, int limit) {
this.maxLen = threshold;
this.trimStrict = false;
this.limit = limit;
return this;
}
@Override @Override
public StreamTrimStrategyArgs<StreamAddArgs<K, V>> trim() { public StreamTrimStrategyArgs<StreamAddArgs<K, V>> trim() {
this.trimStrict = true; this.trimStrict = true;

Loading…
Cancel
Save