File tree Expand file tree Collapse file tree 1 file changed +10
-0
lines changed
tests/src/test/java/io/jooby/i3875 Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -130,10 +130,20 @@ public void onCompleted() {
130130
131131 requestObserver .onNext (
132132 ChatMessage .newBuilder ().setUser ("JavaClient" ).setText ("Ping 1" ).build ());
133+
134+ // Add a tiny delay to prevent CI thread-scheduler race conditions
135+ // where the server closes the stream before Undertow finishes flushing Ping 2.
136+ Thread .sleep (50 );
137+
133138 requestObserver .onNext (
134139 ChatMessage .newBuilder ().setUser ("JavaClient" ).setText ("Ping 2" ).build ());
140+
141+ // Allow Ping 2 to reach the server before sending the close signal
142+ Thread .sleep (50 );
143+
135144 requestObserver .onCompleted ();
136145
146+ // Wait for the server stream to gracefully complete
137147 boolean completed = latch .await (5 , TimeUnit .SECONDS );
138148
139149 assertThat (completed ).isTrue ();
You can’t perform that action at this time.
0 commit comments