File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
rsocket-core/src/test/java/io/rsocket/core Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1085,7 +1085,7 @@ public void shouldTerminateAllStreamsIfThereRacingBetweenDisposeAndRequests(
1085
1085
() -> publisher2 .subscribe (assertSubscriber2 ));
1086
1086
1087
1087
assertSubscriber1 .await ().assertTerminated ();
1088
- if (interactionType1 != REQUEST_FNF ) {
1088
+ if (interactionType1 != REQUEST_FNF && interactionType1 != METADATA_PUSH ) {
1089
1089
assertSubscriber1 .assertError (ClosedChannelException .class );
1090
1090
} else {
1091
1091
try {
@@ -1096,7 +1096,7 @@ public void shouldTerminateAllStreamsIfThereRacingBetweenDisposeAndRequests(
1096
1096
}
1097
1097
}
1098
1098
assertSubscriber2 .await ().assertTerminated ();
1099
- if (interactionType2 != REQUEST_FNF ) {
1099
+ if (interactionType2 != REQUEST_FNF && interactionType2 != METADATA_PUSH ) {
1100
1100
assertSubscriber2 .assertError (ClosedChannelException .class );
1101
1101
} else {
1102
1102
try {
You can’t perform that action at this time.
0 commit comments