@@ -718,10 +718,10 @@ val program =
718
718
// program: Stream[[x]IO[x], Unit] = Stream(..)
719
719
720
720
program.compile.drain.unsafeRunSync()
721
- // 12:19:32.631691618
722
- // 12:19:33.631678810
723
- // 12:19:34.631595960
724
- // 12:19:35.631658364
721
+ // 13:29:00.080601479
722
+ // 13:29:01.080534675
723
+ // 13:29:02.080605881
724
+ // 13:29:03.080531435
725
725
```
726
726
727
727
Let ' s take this line by line now, so we can understand what' s going on.
@@ -763,10 +763,10 @@ val program1 =
763
763
// program1: Stream[[x]IO[x], Unit] = Stream(..)
764
764
765
765
program1.compile.drain.unsafeRunSync()
766
- // 12:19:37.634041570
767
- // 12:19:38.634162212
768
- // 12:19:39.634106075
769
- // 12:19:40.634113967
766
+ // 13:29:05.082964565
767
+ // 13:29:06.082889528
768
+ // 13:29:07.083002508
769
+ // 13:29:08.082870103
770
770
```
771
771
772
772
### Talking to the external world
@@ -799,7 +799,7 @@ The way you bring synchronous effects into your effect type may differ. `Sync.de
799
799
import cats .effect .Sync
800
800
801
801
val T = Sync [IO ]
802
- // T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@16f7b68f
802
+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@32d18a69
803
803
val s2 = Stream .exec(T .delay { destroyUniverse() }) ++ Stream (" ...moving on" )
804
804
// s2: Stream[[x]IO[x], String] = Stream(..)
805
805
s2.compile.toVector.unsafeRunSync()
@@ -933,15 +933,15 @@ stream.toUnicastPublisher
933
933
// source = Bind(
934
934
// source = Eval(
935
935
// fa = Delay(
936
- // thunk = cats.effect.IO$$$Lambda$11358/0x00007f6b47edf2a0@3d55e842 ,
936
+ // thunk = cats.effect.IO$$$Lambda$11292/0x00007f30e3ece0a0@7ef108d8 ,
937
937
// event = cats.effect.tracing.TracingEvent$StackTrace
938
938
// )
939
939
// ),
940
- // fs = cats.effect.std.Supervisor$$$Lambda$12252/0x00007f6b480dd848@5202270e
940
+ // fs = cats.effect.std.Supervisor$$$Lambda$12189/0x00007f30e40cc000@13e9a405
941
941
// ),
942
- // fs = cats.effect.std.Dispatcher$$$Lambda$12253/0x00007f6b480ddc18@ae252ae
942
+ // fs = cats.effect.std.Dispatcher$$$Lambda$12190/0x00007f30e40cc3d0@144fea92
943
943
// ),
944
- // fs = cats.effect.kernel.Resource$$Lambda$12198/0x00007f6b480c5f88@652c4be6
944
+ // fs = cats.effect.kernel.Resource$$Lambda$12135/0x00007f30e40b0e60@74582ffb
945
945
// )
946
946
```
947
947
@@ -954,25 +954,25 @@ val publisher: Resource[IO, StreamUnicastPublisher[IO, Int]] = Stream(1, 2, 3).c
954
954
// source = Bind(
955
955
// source = Eval(
956
956
// fa = Delay(
957
- // thunk = cats.effect.IO$$$Lambda$11358/0x00007f6b47edf2a0@77a9b8f9 ,
957
+ // thunk = cats.effect.IO$$$Lambda$11292/0x00007f30e3ece0a0@2195e60 ,
958
958
// event = cats.effect.tracing.TracingEvent$StackTrace
959
959
// )
960
960
// ),
961
- // fs = cats.effect.std.Supervisor$$$Lambda$12252/0x00007f6b480dd848@3450db55
961
+ // fs = cats.effect.std.Supervisor$$$Lambda$12189/0x00007f30e40cc000@5c8e0baa
962
962
// ),
963
- // fs = cats.effect.std.Dispatcher$$$Lambda$12253/0x00007f6b480ddc18@2cbf9853
963
+ // fs = cats.effect.std.Dispatcher$$$Lambda$12190/0x00007f30e40cc3d0@37fe71d3
964
964
// ),
965
- // fs = cats.effect.kernel.Resource$$Lambda$12198/0x00007f6b480c5f88@2b4b9559
965
+ // fs = cats.effect.kernel.Resource$$Lambda$12135/0x00007f30e40b0e60@26cb720
966
966
// )
967
967
publisher.use { p =>
968
968
p.toStream[IO ].compile.toList
969
969
}
970
970
// res59: IO[List[Int]] = FlatMap(
971
971
// ioe = Delay(
972
- // thunk = cats.effect.IO$$$Lambda$11358/0x00007f6b47edf2a0@77a9b8f9 ,
972
+ // thunk = cats.effect.IO$$$Lambda$11292/0x00007f30e3ece0a0@2195e60 ,
973
973
// event = cats.effect.tracing.TracingEvent$StackTrace
974
974
// ),
975
- // f = cats.effect.kernel.Resource$$Lambda$12255/0x00007f6b480df078@2708077 ,
975
+ // f = cats.effect.kernel.Resource$$Lambda$12192/0x00007f30e40cd630@573fa87f ,
976
976
// event = cats.effect.tracing.TracingEvent$StackTrace
977
977
// )
978
978
```
0 commit comments