@@ -718,10 +718,10 @@ val program =
718718// program: Stream[[x]IO[x], Unit] = Stream(..)
719719
720720program.compile.drain.unsafeRunSync()
721- // 11:15:55.405887211
722- // 11:15:56.405840259
723- // 11:15:57.405839756
724- // 11:15:58.405837482
721+ // 10:59:33.802451043
722+ // 10:59:34.802421143
723+ // 10:59:35.802444230
724+ // 10:59:36.802461152
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- // 11:16:00.408208363
767- // 11:16:01.408165287
768- // 11:16:02.408185764
769- // 11:16:03.408194379
766+ // 10:59:38.804607869
767+ // 10:59:39.804606156
768+ // 10:59:40.804651955
769+ // 10:59:41.804603916
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@2ad88d40
802+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$IOAsync@550f3c76
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$11260/0x00007ff50bea7988@17116f13 ,
936+ // thunk = cats.effect.IO$$$Lambda$12222/0x00007fd2c8053540@582ad521 ,
937937// event = cats.effect.tracing.TracingEvent$StackTrace
938938// )
939939// ),
940- // fs = cats.effect.std.Supervisor$$$Lambda$12175/0x00007ff50c0c1228@5c7ed701
940+ // fs = cats.effect.std.Supervisor$$$Lambda$13139/0x00007fd2c825b020@4399bd4
941941// ),
942- // fs = cats.effect.std.Dispatcher$$$Lambda$12176/0x00007ff50c0c15f8@52e076a5
942+ // fs = cats.effect.std.Dispatcher$$$Lambda$13140/0x00007fd2c825b3f0@3c7d2e9b
943943// ),
944- // fs = cats.effect.kernel.Resource$$Lambda$12118/0x00007ff50c0a5000@3b0de079
944+ // fs = cats.effect.kernel.Resource$$Lambda$13082/0x00007fd2c8242000@2b6215b1
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$11260/0x00007ff50bea7988@27f869fc ,
957+ // thunk = cats.effect.IO$$$Lambda$12222/0x00007fd2c8053540@25ef5e21 ,
958958// event = cats.effect.tracing.TracingEvent$StackTrace
959959// )
960960// ),
961- // fs = cats.effect.std.Supervisor$$$Lambda$12175/0x00007ff50c0c1228@d1474dd
961+ // fs = cats.effect.std.Supervisor$$$Lambda$13139/0x00007fd2c825b020@6dc09673
962962// ),
963- // fs = cats.effect.std.Dispatcher$$$Lambda$12176/0x00007ff50c0c15f8@5c907e84
963+ // fs = cats.effect.std.Dispatcher$$$Lambda$13140/0x00007fd2c825b3f0@389c64a6
964964// ),
965- // fs = cats.effect.kernel.Resource$$Lambda$12118/0x00007ff50c0a5000@84a4347
965+ // fs = cats.effect.kernel.Resource$$Lambda$13082/0x00007fd2c8242000@3e83199
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$11260/0x00007ff50bea7988@27f869fc ,
972+ // thunk = cats.effect.IO$$$Lambda$12222/0x00007fd2c8053540@25ef5e21 ,
973973// event = cats.effect.tracing.TracingEvent$StackTrace
974974// ),
975- // f = cats.effect.kernel.Resource$$Lambda$12178/0x00007ff50c0c2838@8f9f0e2 ,
975+ // f = cats.effect.kernel.Resource$$Lambda$13142/0x00007fd2c8260648@16e06d35 ,
976976// event = cats.effect.tracing.TracingEvent$StackTrace
977977// )
978978```
0 commit comments