Functional Stream for Factorians
Functional Stream for Factorians About Me Senior scala developer Toying with scala since 2016 Joining Zendesk Introduction – Factorio Backpressure Backpressure Backpressure FS2 Let’s get started Mining Drill import fs2.Stream val mineIron: IO[IronOre] = for { _ <- IO.sleep(2.second) _ <- log("Produced 1 Iron ore") } yield IronOre() def ironMiningDrill: Stream[IO, IronOre] = Stream....