Skip to content

Commit 4a1e008

Browse files
committed
Cosmetic fix
1 parent 64f3cf4 commit 4a1e008

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServiceAcceptor.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ public Mono<Payload> requestResponse(Payload payload) {
6161
validateMethodInvoker(methodInvoker, message);
6262
return methodInvoker
6363
.invokeOne(message)
64-
.doOnNext(response -> releaseRequestError(message, response));
64+
.doOnNext(response -> releaseRequestOnError(message, response));
6565
})
6666
.map(this::toPayload);
6767
}
@@ -76,7 +76,7 @@ public Flux<Payload> requestStream(Payload payload) {
7676
validateMethodInvoker(methodInvoker, message);
7777
return methodInvoker
7878
.invokeMany(message)
79-
.doOnNext(response -> releaseRequestError(message, response));
79+
.doOnNext(response -> releaseRequestOnError(message, response));
8080
})
8181
.map(this::toPayload);
8282
}
@@ -94,7 +94,7 @@ public Flux<Payload> requestChannel(Publisher<Payload> payloads) {
9494
methodRegistry.getInvoker(message.qualifier());
9595
return methodInvoker
9696
.invokeBidirectional(messages)
97-
.doOnNext(response -> releaseRequestError(message, response));
97+
.doOnNext(response -> releaseRequestOnError(message, response));
9898
}
9999
return messages;
100100
})
@@ -133,7 +133,7 @@ private void releaseRequest(ServiceMessage request) {
133133
ReferenceCountUtil.safestRelease(request.data());
134134
}
135135

136-
private void releaseRequestError(ServiceMessage request, ServiceMessage response) {
136+
private void releaseRequestOnError(ServiceMessage request, ServiceMessage response) {
137137
if (response.isError()) {
138138
releaseRequest(request);
139139
}

0 commit comments

Comments
 (0)