fixes sink result check condition

OlegDokuka · OlegDokuka · commit 8a41b419db55 · 2020-10-25T12:31:32.000+02:00
Signed-off-by: Oleh Dokuka &lt;shadowgun@i.ua&gt;
diff --git a/rsocket-core/src/main/java/io/rsocket/resume/ResumableDuplexConnection.java b/rsocket-core/src/main/java/io/rsocket/resume/ResumableDuplexConnection.java
@@ -115,7 +115,7 @@ void initConnection(DuplexConnection nextConnection) {
               frameReceivingSubscriber.dispose();
               disposable.dispose();
               Sinks.EmitResult result = onConnectionClosedSink.tryEmitNext(currentConnectionIndex);
-              if (result.equals(Sinks.EmitResult.OK)) {
+              if (!result.equals(Sinks.EmitResult.OK)) {
                 logger.error("Failed to notify session of closed connection: {}", result);
               }
             })

Original file line number	Diff line number	Diff line change
`@@ -115,7 +115,7 @@ void initConnection(DuplexConnection nextConnection) {`
`115`	`115`	`frameReceivingSubscriber.dispose();`
`116`	`116`	`disposable.dispose();`
`117`	`117`	`Sinks.EmitResult result = onConnectionClosedSink.tryEmitNext(currentConnectionIndex);`
`118`		`- if (result.equals(Sinks.EmitResult.OK)) {`
	`118`	`+ if (!result.equals(Sinks.EmitResult.OK)) {`
`119`	`119`	`logger.error("Failed to notify session of closed connection: {}", result);`
`120`	`120`	`}`
`121`	`121`	`})`