[broker-11] fix for code review

JavaSaBr · JavaSaBr · commit 5b9465f5d438 · 2019-11-10T20:23:35.000+03:00
diff --git a/src/main/java/com/ss/mqtt/broker/network/packet/in/handler/ConnectInPacketHandler.java b/src/main/java/com/ss/mqtt/broker/network/packet/in/handler/ConnectInPacketHandler.java
@@ -70,7 +70,7 @@ protected void handleImpl(@NotNull UnsafeMqttClient client, @NotNull ConnectInPa
             return mqttSessionService.restore(client.getClientId())
                 .flatMap(session -> onConnected(client, packet, session, true))
                 .switchIfEmpty(Mono.defer(() -> mqttSessionService.create(client.getClientId())
-                    .flatMap(session -> onConnected(client, packet, session,false))));
+                    .flatMap(session -> onConnected(client, packet, session, false))));
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ protected void handleImpl(@NotNull UnsafeMqttClient client, @NotNull ConnectInPa`
`70`	`70`	`return mqttSessionService.restore(client.getClientId())`
`71`	`71`	`.flatMap(session -> onConnected(client, packet, session, true))`
`72`	`72`	`.switchIfEmpty(Mono.defer(() -> mqttSessionService.create(client.getClientId())`
`73`		`- .flatMap(session -> onConnected(client, packet, session,false))));`
	`73`	`+ .flatMap(session -> onConnected(client, packet, session, false))));`
`74`	`74`	`}`
`75`	`75`	`}`
`76`	`76`