@@ -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:56:04.747765764
594
- // 12:56:05.746701688
595
- // 12:56:06.746431737
596
- // 12:56:07.746418467
593
+ // 12:48:25.008588165
594
+ // 12:48:26.007532870
595
+ // 12:48:27.007130443
596
+ // 12:48:28.007229394
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:56:09.747758101
639
- // 12:56:10.747961853
640
- // 12:56:11.747833563
641
- // 12:56:12.748041120
638
+ // 12:48:30.008205849
639
+ // 12:48:31.008241036
640
+ // 12:48:32.008280210
641
+ // 12:48:33.008242911
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@5fdae459
674
+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@17b4badd
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$11062/0x00007f299be724c0@2a952d50 ,
809
+ // thunk = cats.effect.IO$$$Lambda$10942/0x00007f9a37e424c0@717cdf1b ,
810
810
// event = cats.effect.tracing.TracingEvent$StackTrace
811
811
// )
812
812
// ),
813
- // fs = cats.effect.std.Supervisor$$$Lambda$11750/0x00007f299c01d010@1cf94f9b
813
+ // fs = cats.effect.std.Supervisor$$$Lambda$11630/0x00007f9a37fba5e0@46848850
814
814
// ),
815
- // fs = cats.effect.kernel.Resource$$Lambda$11752/0x00007f299c01d7b0@b928569
815
+ // fs = cats.effect.kernel.Resource$$Lambda$11632/0x00007f9a37fbad80@42d5c898
816
816
// ),
817
- // fs = cats.effect.std.Dispatcher$$$Lambda$11753/0x00007f299c01db80@3e2506e
817
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11633/0x00007f9a37fbb150@7085e04d
818
818
// ),
819
- // fs = cats.effect.kernel.Resource$$Lambda$11752/0x00007f299c01d7b0@1e12ef
819
+ // fs = cats.effect.kernel.Resource$$Lambda$11632/0x00007f9a37fbad80@67967d41
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$11062/0x00007f299be724c0@56cd10e0 ,
833
+ // thunk = cats.effect.IO$$$Lambda$10942/0x00007f9a37e424c0@532bfeb ,
834
834
// event = cats.effect.tracing.TracingEvent$StackTrace
835
835
// )
836
836
// ),
837
- // fs = cats.effect.std.Supervisor$$$Lambda$11750/0x00007f299c01d010@49eb7e9d
837
+ // fs = cats.effect.std.Supervisor$$$Lambda$11630/0x00007f9a37fba5e0@69cf26dd
838
838
// ),
839
- // fs = cats.effect.kernel.Resource$$Lambda$11752/0x00007f299c01d7b0@581b36ee
839
+ // fs = cats.effect.kernel.Resource$$Lambda$11632/0x00007f9a37fbad80@36972421
840
840
// ),
841
- // fs = cats.effect.std.Dispatcher$$$Lambda$11753/0x00007f299c01db80@28e2ce68
841
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11633/0x00007f9a37fbb150@623f3bc7
842
842
// ),
843
- // fs = cats.effect.kernel.Resource$$Lambda$11752/0x00007f299c01d7b0@16168184
843
+ // fs = cats.effect.kernel.Resource$$Lambda$11632/0x00007f9a37fbad80@72621d8c
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$11062/0x00007f299be724c0@56cd10e0 ,
850
+ // thunk = cats.effect.IO$$$Lambda$10942/0x00007f9a37e424c0@532bfeb ,
851
851
// event = cats.effect.tracing.TracingEvent$StackTrace
852
852
// ),
853
- // f = cats.effect.kernel.Resource$$Lambda$11755/0x00007f299c01ebe0@41b0a4d ,
853
+ // f = cats.effect.kernel.Resource$$Lambda$11635/0x00007f9a37fbe278@628b34d3 ,
854
854
// event = cats.effect.tracing.TracingEvent$StackTrace
855
855
// )
856
856
```
0 commit comments