refactoring

pull/5732/head
Nikita Koksharov
parent 41a492dac2
commit 2a10f84e7b

@ -34,6 +34,10 @@ import java.util.concurrent.CompletionException;
*/
public class CommandReactiveService extends CommandAsyncService implements CommandReactiveExecutor {
public CommandReactiveService(CommandAsyncExecutor executor, boolean trackChanges) {
super(executor, trackChanges);
}
public CommandReactiveService(ConnectionManager connectionManager, RedissonObjectBuilder objectBuilder) {
super(connectionManager, objectBuilder, RedissonObjectBuilder.ReferenceType.REACTIVE);
}
@ -42,6 +46,12 @@ public class CommandReactiveService extends CommandAsyncService implements Comma
super(executor, objectParams);
}
@Override
public CommandReactiveExecutor copy(boolean trackChanges) {
return new CommandReactiveService(this, trackChanges);
}
@Override
public CommandReactiveExecutor copy(ObjectParams objectParams) {
return new CommandReactiveService(this, objectParams);
}

@ -36,6 +36,10 @@ import java.util.concurrent.CompletionException;
*/
public class CommandRxService extends CommandAsyncService implements CommandRxExecutor {
public CommandRxService(CommandAsyncExecutor executor, boolean trackChanges) {
super(executor, trackChanges);
}
public CommandRxService(ConnectionManager connectionManager, RedissonObjectBuilder objectBuilder) {
super(connectionManager, objectBuilder, RedissonObjectBuilder.ReferenceType.RXJAVA);
}
@ -44,6 +48,12 @@ public class CommandRxService extends CommandAsyncService implements CommandRxEx
super(executor, objectParams);
}
@Override
public CommandRxExecutor copy(boolean trackChanges) {
return new CommandRxService(this, trackChanges);
}
@Override
public CommandRxExecutor copy(ObjectParams objectParams) {
return new CommandRxService(this, objectParams);
}

Loading…
Cancel
Save