@@ -718,10 +718,10 @@ val program =
718718// program: Stream[[x]IO[x], Unit] = Stream(..)
719719
720720program.compile.drain.unsafeRunSync()
721- // 18:18:36.524558331
722- // 18:18:37.524376600
723- // 18:18:38.524422572
724- // 18:18:39.524417966
721+ // 18:43:16.774959368
722+ // 18:43:17.774911600
723+ // 18:43:18.774924807
724+ // 18:43:19.774950884
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:18:41.526809579
767- // 18:18:42.526853810
768- // 18:18:43.526799377
769- // 18:18:44.526762232
766+ // 18:43:21.777740337
767+ // 18:43:22.777808154
768+ // 18:43:23.777780800
769+ // 18:43:24.777752339
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@6b49d1dc
802+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$IOAsync@6907fdac
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$12392/0x00007f70f0088000@493b5664 ,
936+ // thunk = cats.effect.IO$$$Lambda$11424/0x00007fb23bedb940@775e1983 ,
937937// event = cats.effect.tracing.TracingEvent$StackTrace
938938// )
939939// ),
940- // fs = cats.effect.std.Supervisor$$$Lambda$13313/0x00007f70f029dc50@41f254ab
940+ // fs = cats.effect.std.Supervisor$$$Lambda$12342/0x00007fb23c0f4a28@10851c1f
941941// ),
942- // fs = cats.effect.std.Dispatcher$$$Lambda$13314/0x00007f70f029e020@38af2791
942+ // fs = cats.effect.std.Dispatcher$$$Lambda$12343/0x00007fb23c0f4df8@50abd3ea
943943// ),
944- // fs = cats.effect.kernel.Resource$$Lambda$13254/0x00007f70f0286d90@6a35f72f
944+ // fs = cats.effect.kernel.Resource$$Lambda$12283/0x00007fb23c0d3508@7793460f
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$12392/0x00007f70f0088000@79ae047b ,
957+ // thunk = cats.effect.IO$$$Lambda$11424/0x00007fb23bedb940@7006db7f ,
958958// event = cats.effect.tracing.TracingEvent$StackTrace
959959// )
960960// ),
961- // fs = cats.effect.std.Supervisor$$$Lambda$13313/0x00007f70f029dc50@2a2a50e9
961+ // fs = cats.effect.std.Supervisor$$$Lambda$12342/0x00007fb23c0f4a28@485b5484
962962// ),
963- // fs = cats.effect.std.Dispatcher$$$Lambda$13314/0x00007f70f029e020@6bf87992
963+ // fs = cats.effect.std.Dispatcher$$$Lambda$12343/0x00007fb23c0f4df8@46e1eae6
964964// ),
965- // fs = cats.effect.kernel.Resource$$Lambda$13254/0x00007f70f0286d90@2eb1674d
965+ // fs = cats.effect.kernel.Resource$$Lambda$12283/0x00007fb23c0d3508@2baf6f0b
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$12392/0x00007f70f0088000@79ae047b ,
972+ // thunk = cats.effect.IO$$$Lambda$11424/0x00007fb23bedb940@7006db7f ,
973973// event = cats.effect.tracing.TracingEvent$StackTrace
974974// ),
975- // f = cats.effect.kernel.Resource$$Lambda$13316/0x00007f70f029f260@7da1bcb ,
975+ // f = cats.effect.kernel.Resource$$Lambda$12345/0x00007fb23c0f6038@1800f710 ,
976976// event = cats.effect.tracing.TracingEvent$StackTrace
977977// )
978978```
0 commit comments