refactoring

pull/1827/head
Nikita Koksharov 6 years ago
parent cd4326d6d2
commit 97e582aea4

@ -24,7 +24,7 @@ import org.redisson.client.codec.DoubleCodec;
import org.redisson.client.codec.StringCodec;
import org.redisson.client.protocol.RedisCommands;
import org.redisson.client.protocol.RedisStrictCommand;
import org.redisson.client.protocol.convertor.SingleConvertor;
import org.redisson.client.protocol.convertor.Convertor;
import org.redisson.command.CommandAsyncExecutor;
/**
@ -110,7 +110,7 @@ public class RedissonAtomicDouble extends RedissonExpirable implements RAtomicDo
@Override
public RFuture<Double> getAndAddAsync(final double delta) {
return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, new RedisStrictCommand<Double>("INCRBYFLOAT", new SingleConvertor<Double>() {
return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, new RedisStrictCommand<Double>("INCRBYFLOAT", new Convertor<Double>() {
@Override
public Double convert(Object obj) {
return Double.valueOf(obj.toString()) - delta;

@ -23,7 +23,7 @@ import org.redisson.client.codec.LongCodec;
import org.redisson.client.codec.StringCodec;
import org.redisson.client.protocol.RedisCommands;
import org.redisson.client.protocol.RedisStrictCommand;
import org.redisson.client.protocol.convertor.SingleConvertor;
import org.redisson.client.protocol.convertor.Convertor;
import org.redisson.command.CommandAsyncExecutor;
/**
@ -108,7 +108,7 @@ public class RedissonAtomicLong extends RedissonExpirable implements RAtomicLong
@Override
public RFuture<Long> getAndAddAsync(final long delta) {
return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, new RedisStrictCommand<Long>("INCRBY", new SingleConvertor<Long>() {
return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, new RedisStrictCommand<Long>("INCRBY", new Convertor<Long>() {
@Override
public Long convert(Object obj) {
return ((Long) obj) - delta;

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class BitsSizeReplayConvertor extends SingleConvertor<Long> {
/**
*
* @author Nikita Koksharov
*
*/
public class BitsSizeReplayConvertor implements Convertor<Long> {
@Override
public Long convert(Object obj) {

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class BooleanAmountReplayConvertor extends SingleConvertor<Boolean> {
/**
*
* @author Nikita Koksharov
*
*/
public class BooleanAmountReplayConvertor implements Convertor<Boolean> {
@Override
public Boolean convert(Object obj) {

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class BooleanNotNullReplayConvertor extends SingleConvertor<Boolean> {
/**
*
* @author Nikita Koksharov
*
*/
public class BooleanNotNullReplayConvertor implements Convertor<Boolean> {
@Override
public Boolean convert(Object obj) {

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class BooleanNullReplayConvertor extends SingleConvertor<Boolean> {
/**
*
* @author Nikita Koksharov
*
*/
public class BooleanNullReplayConvertor implements Convertor<Boolean> {
@Override
public Boolean convert(Object obj) {

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class BooleanNullSafeReplayConvertor extends SingleConvertor<Boolean> {
/**
*
* @author Nikita Koksharov
*
*/
public class BooleanNullSafeReplayConvertor implements Convertor<Boolean> {
@Override
public Boolean convert(Object obj) {

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class BooleanNumberReplayConvertor extends SingleConvertor<Boolean> {
/**
*
* @author Nikita Koksharov
*
*/
public class BooleanNumberReplayConvertor implements Convertor<Boolean> {
private long number;

@ -20,7 +20,7 @@ package org.redisson.client.protocol.convertor;
* @author Nikita Koksharov
*
*/
public class BooleanReplayConvertor extends SingleConvertor<Boolean> {
public class BooleanReplayConvertor implements Convertor<Boolean> {
@Override
public Boolean convert(Object obj) {

@ -23,8 +23,6 @@ package org.redisson.client.protocol.convertor;
*/
public interface Convertor<R> {
Object convertMulti(Object obj);
R convert(Object obj);
}

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class DoubleReplayConvertor extends SingleConvertor<Double> {
/**
*
* @author Nikita Koksharov
*
*/
public class DoubleReplayConvertor implements Convertor<Double> {
@Override
public Double convert(Object obj) {

@ -15,7 +15,13 @@
*/
package org.redisson.client.protocol.convertor;
public class EmptyConvertor<R> extends SingleConvertor<R> {
/**
*
* @author Nikita Koksharov
*
* @param <R>
*/
public class EmptyConvertor<R> implements Convertor<R> {
@Override
public R convert(Object obj) {

@ -20,7 +20,7 @@ package org.redisson.client.protocol.convertor;
* @author Nikita Koksharov
*
*/
public class IntegerReplayConvertor extends SingleConvertor<Integer> {
public class IntegerReplayConvertor implements Convertor<Integer> {
private Integer nullValue;

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class LongReplayConvertor extends SingleConvertor<Long> {
/**
*
* @author Nikita Koksharov
*
*/
public class LongReplayConvertor implements Convertor<Long> {
@Override
public Long convert(Object obj) {

@ -17,7 +17,12 @@ package org.redisson.client.protocol.convertor;
import java.math.BigDecimal;
public class NumberConvertor extends SingleConvertor<Object> {
/**
*
* @author Nikita Koksharov
*
*/
public class NumberConvertor implements Convertor<Object> {
private Class<?> resultClass;

@ -1,31 +0,0 @@
/**
* Copyright 2018 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.client.protocol.convertor;
/**
*
* @author Nikita Koksharov
*
* @param <R> type
*/
public abstract class SingleConvertor<R> implements Convertor<R> {
@Override
public Object convertMulti(Object obj) {
return obj;
}
}

@ -22,7 +22,7 @@ import org.redisson.api.StreamMessageId;
* @author Nikita Koksharov
*
*/
public class StreamIdConvertor extends SingleConvertor<StreamMessageId> {
public class StreamIdConvertor implements Convertor<StreamMessageId> {
@Override
public StreamMessageId convert(Object id) {

@ -18,14 +18,12 @@ package org.redisson.client.protocol.convertor;
import java.util.ArrayList;
import java.util.List;
import org.redisson.client.protocol.convertor.SingleConvertor;
/**
*
* @author Nikita Koksharov
*
*/
public class StringToListConvertor extends SingleConvertor<List<String>> {
public class StringToListConvertor implements Convertor<List<String>> {
@Override
public List<String> convert(Object obj) {

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class TrueReplayConvertor extends SingleConvertor<Boolean> {
/**
*
* @author Nikita Koksharov
*
*/
public class TrueReplayConvertor implements Convertor<Boolean> {
@Override
public Boolean convert(Object obj) {

@ -17,7 +17,12 @@ package org.redisson.client.protocol.convertor;
import org.redisson.api.RType;
public class TypeConvertor extends SingleConvertor<RType> {
/**
*
* @author Nikita Koksharov
*
*/
public class TypeConvertor implements Convertor<RType> {
@Override
public RType convert(Object obj) {

@ -15,7 +15,12 @@
*/
package org.redisson.client.protocol.convertor;
public class VoidReplayConvertor extends SingleConvertor<Void> {
/**
*
* @author Nikita Koksharov
*
*/
public class VoidReplayConvertor implements Convertor<Void> {
@Override
public Void convert(Object obj) {

Loading…
Cancel
Save