From 3428316fcf762152ff23ef6a970914c9514bff39 Mon Sep 17 00:00:00 2001 From: Robert Roeser Date: Sun, 23 Dec 2018 05:11:41 -0800 Subject: [PATCH] formatting --- .../java/io/netifi/proteus/DefaultProteusBrokerService.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/proteus-client/src/main/java/io/netifi/proteus/DefaultProteusBrokerService.java b/proteus-client/src/main/java/io/netifi/proteus/DefaultProteusBrokerService.java index 7a934ea..98cfa3f 100644 --- a/proteus-client/src/main/java/io/netifi/proteus/DefaultProteusBrokerService.java +++ b/proteus-client/src/main/java/io/netifi/proteus/DefaultProteusBrokerService.java @@ -69,9 +69,9 @@ public class DefaultProteusBrokerService implements ProteusBrokerService, Dispos private final PresenceNotifier presenceNotifier; private final MonoProcessor onClose; private int missed = 0; - + private final int selectRefresh; - + private volatile Disposable disposable; public DefaultProteusBrokerService( @@ -405,7 +405,7 @@ private synchronized void createConnection() { members.add(rSocket); } } - + private RSocket selectRSocket() { RSocket rSocket; List _m;