Skip to content

Commit ed158f6

Browse files
committed
add sleep test data loss
1 parent de43c76 commit ed158f6

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,11 @@ public CompletableFuture<Void> beforeSendResponseAsync(Invocation invocation, Ht
8686
if (isServerSendEvent(response)) {
8787
produceProcessor = new ProduceEventStreamProcessor();
8888
responseEx.setContentType(produceProcessor.getName() + "; charset=utf-8");
89+
try {
90+
Thread.sleep(10000);
91+
} catch (InterruptedException e) {
92+
throw new RuntimeException(e);
93+
}
8994
return writeServerSendEvent(invocation, response, produceProcessor, responseEx);
9095
}
9196

0 commit comments

Comments
 (0)