Skip to content

Commit 8604923

Browse files
committed
1 parent fe51810 commit 8604923

1 file changed

Lines changed: 13 additions & 10 deletions

File tree

contrib/grpc-spring/src/main/java/com/salesforce/grpc/contrib/spring/GuavaLFReturnValueHandler.java

Lines changed: 13 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import com.google.common.util.concurrent.FutureCallback;
1212
import com.google.common.util.concurrent.Futures;
1313
import com.google.common.util.concurrent.ListenableFuture;
14+
import com.google.common.util.concurrent.MoreExecutors;
1415
import org.springframework.core.MethodParameter;
1516
import org.springframework.web.context.request.NativeWebRequest;
1617
import org.springframework.web.context.request.async.DeferredResult;
@@ -70,17 +71,19 @@ public void handleReturnValue(Object returnValue, MethodParameter returnType, Mo
7071
final DeferredResult<Object> deferredResult = new DeferredResult<>();
7172
@SuppressWarnings("unchecked")
7273
ListenableFuture<Object> futureValue = (ListenableFuture<Object>) returnValue;
73-
Futures.addCallback(futureValue, new FutureCallback<Object>() {
74-
@Override
75-
public void onSuccess(@Nullable Object result) {
76-
deferredResult.setResult(result);
77-
}
74+
Futures.addCallback(futureValue,
75+
new FutureCallback<Object>() {
76+
@Override
77+
public void onSuccess(@Nullable Object result) {
78+
deferredResult.setResult(result);
79+
}
7880

79-
@Override
80-
public void onFailure(Throwable ex) {
81-
deferredResult.setErrorResult(ex);
82-
}
83-
});
81+
@Override
82+
public void onFailure(Throwable ex) {
83+
deferredResult.setErrorResult(ex);
84+
}
85+
},
86+
MoreExecutors.directExecutor());
8487

8588
startDeferredResultProcessing(mavContainer, webRequest, deferredResult);
8689
}

0 commit comments

Comments
 (0)