@@ -718,10 +718,10 @@ val program =
718718// program: Stream[[x]IO[x], Unit] = Stream(..)
719719
720720program.compile.drain.unsafeRunSync()
721- // 18:43:16.774959368
722- // 18:43:17.774911600
723- // 18:43:18.774924807
724- // 18:43:19.774950884
721+ // 19:08:15.072025831
722+ // 19:08:16.071818559
723+ // 19:08:17.071893474
724+ // 19:08:18.071831999
725725```
726726
727727Let ' s take this line by line now, so we can understand what' s going on.
@@ -763,10 +763,10 @@ val program1 =
763763// program1: Stream[[x]IO[x], Unit] = Stream(..)
764764
765765program1.compile.drain.unsafeRunSync()
766- // 18:43:21.777740337
767- // 18:43:22.777808154
768- // 18:43:23.777780800
769- // 18:43:24.777752339
766+ // 19:08:20.074204018
767+ // 19:08:21.074341099
768+ // 19:08:22.074276417
769+ // 19:08:23.074242210
770770```
771771
772772### Talking to the external world
@@ -799,7 +799,7 @@ The way you bring synchronous effects into your effect type may differ. `Sync.de
799799import cats .effect .Sync
800800
801801val T = Sync [IO ]
802- // T: cats.effect.kernel.Async[IO] = cats.effect.IO$IOAsync@6907fdac
802+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$IOAsync@2e72b321
803803val s2 = Stream .exec(T .delay { destroyUniverse() }) ++ Stream (" ...moving on" )
804804// s2: Stream[[x]IO[x], String] = Stream(..)
805805s2.compile.toVector.unsafeRunSync()
@@ -933,15 +933,15 @@ stream.toUnicastPublisher
933933// source = Bind(
934934// source = Eval(
935935// fa = Delay(
936- // thunk = cats.effect.IO$$$Lambda$11424/0x00007fb23bedb940@775e1983 ,
936+ // thunk = cats.effect.IO$$$Lambda$12383/0x00007f3738085eb0@2f40d801 ,
937937// event = cats.effect.tracing.TracingEvent$StackTrace
938938// )
939939// ),
940- // fs = cats.effect.std.Supervisor$$$Lambda$12342/0x00007fb23c0f4a28@10851c1f
940+ // fs = cats.effect.std.Supervisor$$$Lambda$13309/0x00007f373829d848@76c8cf3a
941941// ),
942- // fs = cats.effect.std.Dispatcher$$$Lambda$12343/0x00007fb23c0f4df8@50abd3ea
942+ // fs = cats.effect.std.Dispatcher$$$Lambda$13310/0x00007f373829dc18@68a2e3ea
943943// ),
944- // fs = cats.effect.kernel.Resource$$Lambda$12283/0x00007fb23c0d3508@7793460f
944+ // fs = cats.effect.kernel.Resource$$Lambda$13250/0x00007f37382873c0@1c9c1ce6
945945// )
946946```
947947
@@ -954,25 +954,25 @@ val publisher: Resource[IO, StreamUnicastPublisher[IO, Int]] = Stream(1, 2, 3).c
954954// source = Bind(
955955// source = Eval(
956956// fa = Delay(
957- // thunk = cats.effect.IO$$$Lambda$11424/0x00007fb23bedb940@7006db7f ,
957+ // thunk = cats.effect.IO$$$Lambda$12383/0x00007f3738085eb0@35b54fa4 ,
958958// event = cats.effect.tracing.TracingEvent$StackTrace
959959// )
960960// ),
961- // fs = cats.effect.std.Supervisor$$$Lambda$12342/0x00007fb23c0f4a28@485b5484
961+ // fs = cats.effect.std.Supervisor$$$Lambda$13309/0x00007f373829d848@534f737
962962// ),
963- // fs = cats.effect.std.Dispatcher$$$Lambda$12343/0x00007fb23c0f4df8@46e1eae6
963+ // fs = cats.effect.std.Dispatcher$$$Lambda$13310/0x00007f373829dc18@7af6e9c8
964964// ),
965- // fs = cats.effect.kernel.Resource$$Lambda$12283/0x00007fb23c0d3508@2baf6f0b
965+ // fs = cats.effect.kernel.Resource$$Lambda$13250/0x00007f37382873c0@671a15c
966966// )
967967publisher.use { p =>
968968 p.toStream[IO ].compile.toList
969969}
970970// res59: IO[List[Int]] = FlatMap(
971971// ioe = Delay(
972- // thunk = cats.effect.IO$$$Lambda$11424/0x00007fb23bedb940@7006db7f ,
972+ // thunk = cats.effect.IO$$$Lambda$12383/0x00007f3738085eb0@35b54fa4 ,
973973// event = cats.effect.tracing.TracingEvent$StackTrace
974974// ),
975- // f = cats.effect.kernel.Resource$$Lambda$12345/0x00007fb23c0f6038@1800f710 ,
975+ // f = cats.effect.kernel.Resource$$Lambda$13312/0x00007f373829ee58@21f5e40d ,
976976// event = cats.effect.tracing.TracingEvent$StackTrace
977977// )
978978```
0 commit comments