Skip to content

Commit 7076c84

Browse files
committed
add flushBuffer
1 parent 9f7a9dc commit 7076c84

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

common/common-rest/src/main/java/org/apache/servicecomb/common/rest/filter/inner/ServerRestArgsFilter.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
import static org.apache.servicecomb.common.rest.filter.inner.RestServerCodecFilter.isDownloadFileResponseType;
2121

22+
import java.io.IOException;
2223
import java.util.Map;
2324
import java.util.concurrent.CompletableFuture;
2425

@@ -167,6 +168,11 @@ private static CompletableFuture<Response> writeResponse(
167168
if (e != null) {
168169
result.completeExceptionally(e);
169170
}
171+
try {
172+
responseEx.flushBuffer();
173+
} catch (IOException ex) {
174+
LOGGER.warn("Failed to flush buffer for Server Send Events", ex);
175+
}
170176
});
171177
result.complete(response);
172178
return result;

0 commit comments

Comments
 (0)