@@ -590,10 +590,10 @@ val program =
590
590
// program: Stream[[x]IO[x], Unit] = Stream(..)
591
591
592
592
program.compile.drain.unsafeRunSync()
593
- // 12:48:25.008588165
594
- // 12:48:26.007532870
595
- // 12:48:27.007130443
596
- // 12:48:28.007229394
593
+ // 01:57:42.908812258
594
+ // 01:57:43.907707997
595
+ // 01:57:44.907485616
596
+ // 01:57:45.907509770
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
- // 12:48:30.008205849
639
- // 12:48:31.008241036
640
- // 12:48:32.008280210
641
- // 12:48:33.008242911
638
+ // 01:57:47.909651757
639
+ // 01:57:48.909916726
640
+ // 01:57:49.909698675
641
+ // 01:57:50.909873881
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@17b4badd
674
+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@72d7e255
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$10942/0x00007f9a37e424c0@717cdf1b ,
809
+ // thunk = cats.effect.IO$$$Lambda$10910/0x00007f0cc7e3a4c0@241642ff ,
810
810
// event = cats.effect.tracing.TracingEvent$StackTrace
811
811
// )
812
812
// ),
813
- // fs = cats.effect.std.Supervisor$$$Lambda$11630/0x00007f9a37fba5e0@46848850
813
+ // fs = cats.effect.std.Supervisor$$$Lambda$11607/0x00007f0cc7fb7510@4f788064
814
814
// ),
815
- // fs = cats.effect.kernel.Resource$$Lambda$11632/0x00007f9a37fbad80@42d5c898
815
+ // fs = cats.effect.kernel.Resource$$Lambda$11609/0x00007f0cc7fb8000@16d06f3a
816
816
// ),
817
- // fs = cats.effect.std.Dispatcher$$$Lambda$11633/0x00007f9a37fbb150@7085e04d
817
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11610/0x00007f0cc7fb83d0@5b58e2ff
818
818
// ),
819
- // fs = cats.effect.kernel.Resource$$Lambda$11632/0x00007f9a37fbad80@67967d41
819
+ // fs = cats.effect.kernel.Resource$$Lambda$11609/0x00007f0cc7fb8000@4d4f52d1
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$10942/0x00007f9a37e424c0@532bfeb ,
833
+ // thunk = cats.effect.IO$$$Lambda$10910/0x00007f0cc7e3a4c0@46bf80bc ,
834
834
// event = cats.effect.tracing.TracingEvent$StackTrace
835
835
// )
836
836
// ),
837
- // fs = cats.effect.std.Supervisor$$$Lambda$11630/0x00007f9a37fba5e0@69cf26dd
837
+ // fs = cats.effect.std.Supervisor$$$Lambda$11607/0x00007f0cc7fb7510@53838eee
838
838
// ),
839
- // fs = cats.effect.kernel.Resource$$Lambda$11632/0x00007f9a37fbad80@36972421
839
+ // fs = cats.effect.kernel.Resource$$Lambda$11609/0x00007f0cc7fb8000@4f50d17b
840
840
// ),
841
- // fs = cats.effect.std.Dispatcher$$$Lambda$11633/0x00007f9a37fbb150@623f3bc7
841
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11610/0x00007f0cc7fb83d0@78becb9a
842
842
// ),
843
- // fs = cats.effect.kernel.Resource$$Lambda$11632/0x00007f9a37fbad80@72621d8c
843
+ // fs = cats.effect.kernel.Resource$$Lambda$11609/0x00007f0cc7fb8000@423e0e51
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$10942/0x00007f9a37e424c0@532bfeb ,
850
+ // thunk = cats.effect.IO$$$Lambda$10910/0x00007f0cc7e3a4c0@46bf80bc ,
851
851
// event = cats.effect.tracing.TracingEvent$StackTrace
852
852
// ),
853
- // f = cats.effect.kernel.Resource$$Lambda$11635/0x00007f9a37fbe278@628b34d3 ,
853
+ // f = cats.effect.kernel.Resource$$Lambda$11612/0x00007f0cc7fb9230@d851c06 ,
854
854
// event = cats.effect.tracing.TracingEvent$StackTrace
855
855
// )
856
856
```
0 commit comments