We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d676edd commit 63d0cd7Copy full SHA for 63d0cd7
core/shared/src/test/scala/fs2/StreamCombinatorsSuite.scala
@@ -847,7 +847,9 @@ class StreamCombinatorsSuite extends Fs2Suite {
847
downstream.compile.lastOrError.intercept[SevenNotAllowed.type]
848
}
849
850
- test("upstream interruption causes immediate downstream termination with all elements being emitted") {
+ test(
851
+ "upstream interruption causes immediate downstream termination with all elements being emitted"
852
+ ) {
853
854
val sourceTimeout = 5.5.seconds
855
val downstreamTimeout = sourceTimeout + 2.seconds
0 commit comments