@@ -718,10 +718,10 @@ val program =
718718// program: Stream[[x]IO[x], Unit] = Stream(..)
719719
720720program.compile.drain.unsafeRunSync()
721- // 12:22:30.851628711
722- // 12:22:31.851632774
723- // 12:22:32.851712735
724- // 12:22:33.851689496
721+ // 13:18:22.528587973
722+ // 13:18:23.528558422
723+ // 13:18:24.528551972
724+ // 13:18:25.528508086
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- // 12:22:35.854122142
767- // 12:22:36.854092880
768- // 12:22:37.854156972
769- // 12:22:38.854131327
766+ // 13:18:27.530792273
767+ // 13:18:28.530811877
768+ // 13:18:29.530701086
769+ // 13:18:30.530705745
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@67a58410
802+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$IOAsync@6e9f9b84
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$12275/0x00007fb04c05fb88@511a501e ,
936+ // thunk = cats.effect.IO$$$Lambda$11187/0x00007f093fea3540@6311a8c7 ,
937937// event = cats.effect.tracing.TracingEvent$StackTrace
938938// )
939939// ),
940- // fs = cats.effect.std.Supervisor$$$Lambda$13200/0x00007fb04c272398@7b580752
940+ // fs = cats.effect.std.Supervisor$$$Lambda$12116/0x00007f09400c4000@4e19d2f9
941941// ),
942- // fs = cats.effect.std.Dispatcher$$$Lambda$13201/0x00007fb04c272768@1558018d
942+ // fs = cats.effect.std.Dispatcher$$$Lambda$12117/0x00007f09400c43d0@2f48212a
943943// ),
944- // fs = cats.effect.kernel.Resource$$Lambda$13141/0x00007fb04c25e870@2f73d8c1
944+ // fs = cats.effect.kernel.Resource$$Lambda$12057/0x00007f09400a59a0@b730c27
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$12275/0x00007fb04c05fb88@2ceae791 ,
957+ // thunk = cats.effect.IO$$$Lambda$11187/0x00007f093fea3540@654aca1e ,
958958// event = cats.effect.tracing.TracingEvent$StackTrace
959959// )
960960// ),
961- // fs = cats.effect.std.Supervisor$$$Lambda$13200/0x00007fb04c272398@173317c9
961+ // fs = cats.effect.std.Supervisor$$$Lambda$12116/0x00007f09400c4000@65445254
962962// ),
963- // fs = cats.effect.std.Dispatcher$$$Lambda$13201/0x00007fb04c272768@423238cb
963+ // fs = cats.effect.std.Dispatcher$$$Lambda$12117/0x00007f09400c43d0@beb7ea7
964964// ),
965- // fs = cats.effect.kernel.Resource$$Lambda$13141/0x00007fb04c25e870@7336459c
965+ // fs = cats.effect.kernel.Resource$$Lambda$12057/0x00007f09400a59a0@186a59c9
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$12275/0x00007fb04c05fb88@2ceae791 ,
972+ // thunk = cats.effect.IO$$$Lambda$11187/0x00007f093fea3540@654aca1e ,
973973// event = cats.effect.tracing.TracingEvent$StackTrace
974974// ),
975- // f = cats.effect.kernel.Resource$$Lambda$13203/0x00007fb04c2739a8@c62ffe2 ,
975+ // f = cats.effect.kernel.Resource$$Lambda$12119/0x00007f09400c5410@38a37485 ,
976976// event = cats.effect.tracing.TracingEvent$StackTrace
977977// )
978978```
0 commit comments