Skip to content

Commit 8b211cd

Browse files
authored
Merge pull request #15 from kiambogo/fixReadme
Update Readme to reflect fs2 1.0.0 changes
2 parents dddb4dd + 3f3e2ba commit 8b211cd

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

README.md

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -94,15 +94,13 @@ you can then do:
9494

9595
``` scala
9696
import upperbound._, syntax.rate._
97-
import fs2.StreamApp
98-
import fs2.StreamApp.ExitCode
9997
import fs2.Stream
100-
import cats.effect.IO
98+
import cats.effect.{IO, IOApp, ExitCode}
10199
import scala.concurrent.ExecutionContext.Implicits.global
102100
import scala.concurrent.duration._
103101

104-
object Main extends StreamApp[IO] {
105-
override def stream(args: List[String], requestShutdown: IO[Unit]) : Stream[IO, ExitCode] =
102+
object Main extends IOApp {
103+
override def run(args: List[String]): IO[ExitCode] =
106104
for {
107105
limiter <- Limiter.stream[IO](100 every 1.minute)
108106
res <- Stream.eval(YourWholeProgram(limiter.worker).doStuff).as(ExitCode.Success)

0 commit comments

Comments
 (0)