@@ -590,10 +590,10 @@ val program =
590
590
// program: Stream[[x]IO[x], Unit] = Stream(..)
591
591
592
592
program.compile.drain.unsafeRunSync()
593
- // 03:43:43.049829192
594
- // 03:43:44.048573906
595
- // 03:43:45.048218257
596
- // 03:43:46.048104357
593
+ // 23: 03:05.967463585
594
+ // 23: 03:06.966244043
595
+ // 23: 03:07.965998001
596
+ // 23: 03:08.965989137
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
- // 03:43:48.049264635
639
- // 03:43:49.049182848
640
- // 03:43:50.049397692
641
- // 03:43:51.049429617
638
+ // 23: 03:10.967425943
639
+ // 23: 03:11.967447484
640
+ // 23: 03:12.967462143
641
+ // 23: 03:13.967506072
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@78e429dc
674
+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@7f3d5271
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$11964/0x00007fa5d3fd18c0@2a92dfb1 ,
809
+ // thunk = cats.effect.IO$$$Lambda$10975/0x00007fd5bfe424c0@76c3cef ,
810
810
// event = cats.effect.tracing.TracingEvent$StackTrace
811
811
// )
812
812
// ),
813
- // fs = cats.effect.std.Supervisor$$$Lambda$12659/0x00007fa5d417d010@2d40cc56
813
+ // fs = cats.effect.std.Supervisor$$$Lambda$11676/0x00007fd5bffeed78@3a23087a
814
814
// ),
815
- // fs = cats.effect.kernel.Resource$$Lambda$12661/0x00007fa5d417d7b0@375aa20f
815
+ // fs = cats.effect.kernel.Resource$$Lambda$11678/0x00007fd5bffef518@4d84be07
816
816
// ),
817
- // fs = cats.effect.std.Dispatcher$$$Lambda$12662/0x00007fa5d417db80@6e29d7f1
817
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11679/0x00007fd5bffef8e8@58bfc31c
818
818
// ),
819
- // fs = cats.effect.kernel.Resource$$Lambda$12661/0x00007fa5d417d7b0@52fae2d2
819
+ // fs = cats.effect.kernel.Resource$$Lambda$11678/0x00007fd5bffef518@3ed217a0
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$11964/0x00007fa5d3fd18c0@79f3a6a7 ,
833
+ // thunk = cats.effect.IO$$$Lambda$10975/0x00007fd5bfe424c0@1c90a8d8 ,
834
834
// event = cats.effect.tracing.TracingEvent$StackTrace
835
835
// )
836
836
// ),
837
- // fs = cats.effect.std.Supervisor$$$Lambda$12659/0x00007fa5d417d010@1bdb294c
837
+ // fs = cats.effect.std.Supervisor$$$Lambda$11676/0x00007fd5bffeed78@748c59cb
838
838
// ),
839
- // fs = cats.effect.kernel.Resource$$Lambda$12661/0x00007fa5d417d7b0@3b6df399
839
+ // fs = cats.effect.kernel.Resource$$Lambda$11678/0x00007fd5bffef518@520dd365
840
840
// ),
841
- // fs = cats.effect.std.Dispatcher$$$Lambda$12662/0x00007fa5d417db80@3e847a54
841
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11679/0x00007fd5bffef8e8@7ccca193
842
842
// ),
843
- // fs = cats.effect.kernel.Resource$$Lambda$12661/0x00007fa5d417d7b0@5a2635bd
843
+ // fs = cats.effect.kernel.Resource$$Lambda$11678/0x00007fd5bffef518@658300ba
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$11964/0x00007fa5d3fd18c0@79f3a6a7 ,
850
+ // thunk = cats.effect.IO$$$Lambda$10975/0x00007fd5bfe424c0@1c90a8d8 ,
851
851
// event = cats.effect.tracing.TracingEvent$StackTrace
852
852
// ),
853
- // f = cats.effect.kernel.Resource$$Lambda$12664/0x00007fa5d417ebe0@18f5f6fc ,
853
+ // f = cats.effect.kernel.Resource$$Lambda$11681/0x00007fd5bfff4a90@73d74fc0 ,
854
854
// event = cats.effect.tracing.TracingEvent$StackTrace
855
855
// )
856
856
```
0 commit comments