Skip to content

Commit

Permalink
Spotless
Browse files Browse the repository at this point in the history
Signed-off-by: Andrew Carbonetto <[email protected]>
  • Loading branch information
acarbonetto committed Jan 17, 2024
1 parent 2807e82 commit a31632f
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 8 deletions.
3 changes: 2 additions & 1 deletion java/client/src/main/java/glide/api/RedisClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,8 @@ public class RedisClient extends BaseClient implements BaseCommands {
public static CompletableFuture<RedisClient> CreateClient(RedisClientConfiguration config) {
ThreadPoolResource threadPoolResource = config.getThreadPoolResource();
if (threadPoolResource == null) {
threadPoolResource = ThreadPoolResourceAllocator.getOrCreate(Platform.getThreadPoolResourceSupplier());
threadPoolResource =
ThreadPoolResourceAllocator.getOrCreate(Platform.getThreadPoolResourceSupplier());
}
ChannelHandler channelHandler = buildChannelHandler(threadPoolResource);
var connectionManager = buildConnectionManager(channelHandler);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,7 @@ public EpollResource() {
this(
new EpollEventLoopGroup(
Runtime.getRuntime().availableProcessors(),
new DefaultThreadFactory(EPOLL_EVENT_LOOP_IDENTIFIER, true))
);
new DefaultThreadFactory(EPOLL_EVENT_LOOP_IDENTIFIER, true)));
}

public EpollResource(EpollEventLoopGroup epollEventLoopGroup) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,7 @@ public KQueuePoolResource() {
this(
new KQueueEventLoopGroup(
Runtime.getRuntime().availableProcessors(),
new DefaultThreadFactory(KQUEUE_EVENT_LOOP_IDENTIFIER, true))
);
new DefaultThreadFactory(KQUEUE_EVENT_LOOP_IDENTIFIER, true)));
}

public KQueuePoolResource(KQueueEventLoopGroup eventLoopGroup) {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,10 +1,7 @@
package glide.connectors.resources;

import io.netty.channel.epoll.Epoll;
import io.netty.channel.epoll.EpollDomainSocketChannel;
import io.netty.channel.kqueue.KQueue;
import io.netty.channel.kqueue.KQueueDomainSocketChannel;
import io.netty.channel.unix.DomainSocketChannel;
import java.util.function.Supplier;
import lombok.AccessLevel;
import lombok.AllArgsConstructor;
Expand Down

0 comments on commit a31632f

Please sign in to comment.