@@ -718,10 +718,10 @@ val program =
718718// program: Stream[[x]IO[x], Unit] = Stream(..)
719719
720720program.compile.drain.unsafeRunSync()
721- // 12:08:57.483690851
722- // 12:08:58.483645409
723- // 12:08:59.483682279
724- // 12:09:00.483652233
721+ // 12:27:53.388336057
722+ // 12:27:54.388273308
723+ // 12:27:55.388348117
724+ // 12:27:56.388270440
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:09:02.486351837
767- // 12:09:03.486446792
768- // 12:09:04.486309339
769- // 12:09:05.486349664
766+ // 12:27:58.390758680
767+ // 12:27:59.390788620
768+ // 12:28:00.390838371
769+ // 12:28:01.390877554
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@2e5b7d03
802+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$IOAsync@6140103d
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$11347/0x00007f1af7ed6d88@2b7f67ae ,
936+ // thunk = cats.effect.IO$$$Lambda$11270/0x00007f1a1fed90c8@e93acb6 ,
937937// event = cats.effect.tracing.TracingEvent$StackTrace
938938// )
939939// ),
940- // fs = cats.effect.std.Supervisor$$$Lambda$12272/0x00007f1af80ba860@26c47e32
940+ // fs = cats.effect.std.Supervisor$$$Lambda$12202/0x00007f1a200f4c30@498fc8d1
941941// ),
942- // fs = cats.effect.std.Dispatcher$$$Lambda$12273/0x00007f1af80bac30@75b5ba38
942+ // fs = cats.effect.std.Dispatcher$$$Lambda$12203/0x00007f1a200f5000@1ba1517c
943943// ),
944- // fs = cats.effect.kernel.Resource$$Lambda$12213/0x00007f1af80a6188@5f2b1d99
944+ // fs = cats.effect.kernel.Resource$$Lambda$12143/0x00007f1a200d8ba0@663f24f3
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$11347/0x00007f1af7ed6d88@f3953c5 ,
957+ // thunk = cats.effect.IO$$$Lambda$11270/0x00007f1a1fed90c8@755ac29e ,
958958// event = cats.effect.tracing.TracingEvent$StackTrace
959959// )
960960// ),
961- // fs = cats.effect.std.Supervisor$$$Lambda$12272/0x00007f1af80ba860@a0999fe
961+ // fs = cats.effect.std.Supervisor$$$Lambda$12202/0x00007f1a200f4c30@422455a4
962962// ),
963- // fs = cats.effect.std.Dispatcher$$$Lambda$12273/0x00007f1af80bac30@52b596fd
963+ // fs = cats.effect.std.Dispatcher$$$Lambda$12203/0x00007f1a200f5000@539fc62d
964964// ),
965- // fs = cats.effect.kernel.Resource$$Lambda$12213/0x00007f1af80a6188@55f58ee7
965+ // fs = cats.effect.kernel.Resource$$Lambda$12143/0x00007f1a200d8ba0@4c187811
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$11347/0x00007f1af7ed6d88@f3953c5 ,
972+ // thunk = cats.effect.IO$$$Lambda$11270/0x00007f1a1fed90c8@755ac29e ,
973973// event = cats.effect.tracing.TracingEvent$StackTrace
974974// ),
975- // f = cats.effect.kernel.Resource$$Lambda$12275/0x00007f1af80c0000@123f5eb0 ,
975+ // f = cats.effect.kernel.Resource$$Lambda$12205/0x00007f1a200f6240@207a01e ,
976976// event = cats.effect.tracing.TracingEvent$StackTrace
977977// )
978978```
0 commit comments