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 b8a114a commit f6eb87fCopy full SHA for f6eb87f
1 file changed
fs2/src/test/scala/sttp/capabilities/fs2/Fs2StreamsTest.scala
@@ -1,13 +1,22 @@
1
package sttp.capabilities.fs2
2
3
import cats.effect.IO
4
-import cats.effect.unsafe.implicits.global
+import cats.effect.unsafe
5
import fs2._
6
import org.scalatest.flatspec.AsyncFlatSpec
7
import org.scalatest.matchers.should.Matchers
8
import sttp.capabilities.StreamMaxLengthExceededException
9
10
class Fs2StreamsTest extends AsyncFlatSpec with Matchers {
11
+
12
+ implicit val runtime: unsafe.IORuntime = unsafe.IORuntime(
13
+ executionContext,
14
15
+ unsafe.IORuntime.global.scheduler,
16
+ unsafe.IORuntime.global.shutdown,
17
+ unsafe.IORuntime.global.config
18
+ )
19
20
behavior of "Fs2Streams"
21
22
it should "Pass all bytes if limit is not exceeded" in {
0 commit comments