@@ -590,10 +590,10 @@ val program =
590
590
// program: Stream[[x]IO[x], Unit] = Stream(..)
591
591
592
592
program.compile.drain.unsafeRunSync()
593
- // 15:24:45.923798736
594
- // 15:24:46.922865918
595
- // 15:24:47.922427504
596
- // 15:24:48.922604325
593
+ // 13:30:04.518919960
594
+ // 13:30:05.517546422
595
+ // 13:30:06.517323086
596
+ // 13:30:07.517247226
597
597
```
598
598
599
599
Let ' s take this line by line now, so we can understand what' s going on.
@@ -635,10 +635,10 @@ val program1 =
635
635
// program1: Stream[[x]IO[x], Unit] = Stream(..)
636
636
637
637
program1.compile.drain.unsafeRunSync()
638
- // 15:24:50.924616180
639
- // 15:24:51.924473847
640
- // 15:24:52.924473797
641
- // 15:24:53.924490087
638
+ // 13:30:09.518542889
639
+ // 13:30:10.518721022
640
+ // 13:30:11.518540920
641
+ // 13:30:12.518606537
642
642
```
643
643
644
644
### Talking to the external world
@@ -671,7 +671,7 @@ The way you bring synchronous effects into your effect type may differ. `Sync.de
671
671
import cats .effect .Sync
672
672
673
673
val T = Sync [IO ]
674
- // T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@292f046c
674
+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@63f21dd9
675
675
val s2 = Stream .exec(T .delay { destroyUniverse() }) ++ Stream (" ...moving on" )
676
676
// s2: Stream[[x]IO[x], String] = Stream(..)
677
677
s2.compile.toVector.unsafeRunSync()
@@ -806,17 +806,17 @@ stream.toUnicastPublisher
806
806
// source = Bind(
807
807
// source = Eval(
808
808
// fa = Delay(
809
- // thunk = cats.effect.IO$$$Lambda$10868/0x00007f7fafe0e0a0@4a4eb35c ,
809
+ // thunk = cats.effect.IO$$$Lambda$10998/0x00007fd7b3e326c0@21b4972a ,
810
810
// event = cats.effect.tracing.TracingEvent$StackTrace
811
811
// )
812
812
// ),
813
- // fs = cats.effect.std.Supervisor$$$Lambda$11546/0x00007f7faffba7a8@5a40ef58
813
+ // fs = cats.effect.std.Supervisor$$$Lambda$11690/0x00007fd7b3fded78@317fa540
814
814
// ),
815
- // fs = cats.effect.kernel.Resource$$Lambda$11548/0x00007f7faffbaf48@142bf55d
815
+ // fs = cats.effect.kernel.Resource$$Lambda$11692/0x00007fd7b3fdf518@419646d
816
816
// ),
817
- // fs = cats.effect.std.Dispatcher$$$Lambda$11549/0x00007f7faffbb318@45f69fd0
817
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11693/0x00007fd7b3fdf8e8@7776ade2
818
818
// ),
819
- // fs = cats.effect.kernel.Resource$$Lambda$11548/0x00007f7faffbaf48@7a1d0061
819
+ // fs = cats.effect.kernel.Resource$$Lambda$11692/0x00007fd7b3fdf518@727e69e1
820
820
// )
821
821
```
822
822
@@ -830,27 +830,27 @@ val publisher: Resource[IO, StreamUnicastPublisher[IO, Int]] = Stream(1, 2, 3).c
830
830
// source = Bind(
831
831
// source = Eval(
832
832
// fa = Delay(
833
- // thunk = cats.effect.IO$$$Lambda$10868/0x00007f7fafe0e0a0@277a0a55 ,
833
+ // thunk = cats.effect.IO$$$Lambda$10998/0x00007fd7b3e326c0@3e67974b ,
834
834
// event = cats.effect.tracing.TracingEvent$StackTrace
835
835
// )
836
836
// ),
837
- // fs = cats.effect.std.Supervisor$$$Lambda$11546/0x00007f7faffba7a8@6cb082fa
837
+ // fs = cats.effect.std.Supervisor$$$Lambda$11690/0x00007fd7b3fded78@7192a6e6
838
838
// ),
839
- // fs = cats.effect.kernel.Resource$$Lambda$11548/0x00007f7faffbaf48@1dc988a3
839
+ // fs = cats.effect.kernel.Resource$$Lambda$11692/0x00007fd7b3fdf518@33491c8b
840
840
// ),
841
- // fs = cats.effect.std.Dispatcher$$$Lambda$11549/0x00007f7faffbb318@fc58d73
841
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11693/0x00007fd7b3fdf8e8@32f94a62
842
842
// ),
843
- // fs = cats.effect.kernel.Resource$$Lambda$11548/0x00007f7faffbaf48@789a167c
843
+ // fs = cats.effect.kernel.Resource$$Lambda$11692/0x00007fd7b3fdf518@30264eb9
844
844
// )
845
845
publisher.use { p =>
846
846
p.toStream[IO ].compile.toList
847
847
}
848
848
// res56: IO[List[Int]] = FlatMap(
849
849
// ioe = Delay(
850
- // thunk = cats.effect.IO$$$Lambda$10868/0x00007f7fafe0e0a0@277a0a55 ,
850
+ // thunk = cats.effect.IO$$$Lambda$10998/0x00007fd7b3e326c0@3e67974b ,
851
851
// event = cats.effect.tracing.TracingEvent$StackTrace
852
852
// ),
853
- // f = cats.effect.kernel.Resource$$Lambda$11551/0x00007f7faffbe498@1055fcc7 ,
853
+ // f = cats.effect.kernel.Resource$$Lambda$11695/0x00007fd7b3fe4a90@54e76bcd ,
854
854
// event = cats.effect.tracing.TracingEvent$StackTrace
855
855
// )
856
856
```
0 commit comments