Skip to content

Commit

Permalink
Merge branch 'jedis-x2' into JedisXBinaryCommands_pipeline_commands
Browse files Browse the repository at this point in the history
  • Loading branch information
AvitalFineRedis committed Oct 28, 2021
2 parents 9c93a86 + 9fa96a4 commit 80f5a57
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 6 deletions.
6 changes: 4 additions & 2 deletions src/main/java/redis/clients/jedis/Jedis.java
Original file line number Diff line number Diff line change
Expand Up @@ -4194,12 +4194,14 @@ public long pfcount(final byte[]... keys) {

@Override
public ScanResult<byte[]> scan(final byte[] cursor) {
return scan(cursor, new ScanParams());
checkIsInMultiOrPipeline();
return connection.executeCommand(commandObjects.scan(cursor));
}

@Override
public ScanResult<byte[]> scan(final byte[] cursor, final ScanParams params) {
return scan(cursor, params, (byte[]) null);
checkIsInMultiOrPipeline();
return connection.executeCommand(commandObjects.scan(cursor, params));
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ public void close() {
}

@Override
public Connection getConnection(CommandArguments args) {
public final Connection getConnection(CommandArguments args) {
return connection;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,11 +4,11 @@
import redis.clients.jedis.Connection;
import redis.clients.jedis.util.Pool;

public class PooledJedisConnectionProvider<C extends Connection> implements JedisConnectionProvider {
public class PooledJedisConnectionProvider implements JedisConnectionProvider {

private final Pool<C> pool;
private final Pool<Connection> pool;

public PooledJedisConnectionProvider(Pool<C> pool) {
public PooledJedisConnectionProvider(Pool<Connection> pool) {
this.pool = pool;
}

Expand Down

0 comments on commit 80f5a57

Please sign in to comment.