@@ -590,10 +590,10 @@ val program =
590
590
// program: Stream[[x]IO[x], Unit] = Stream(..)
591
591
592
592
program.compile.drain.unsafeRunSync()
593
- // 13:54:19.549661223
594
- // 13:54:20.548427759
595
- // 13:54:21.548395207
596
- // 13:54:22.548099811
593
+ // 12:56:04.747765764
594
+ // 12:56:05.746701688
595
+ // 12:56:06.746431737
596
+ // 12:56:07.746418467
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
- // 13:54:24.549997435
639
- // 13:54:25.550049856
640
- // 13:54:26.550035015
641
- // 13:54:27.550041825
638
+ // 12:56:09.747758101
639
+ // 12:56:10.747961853
640
+ // 12:56:11.747833563
641
+ // 12:56:12.748041120
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@3811edf5
674
+ // T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@5fdae459
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$11805/0x00007f055bf924c0@16224480 ,
809
+ // thunk = cats.effect.IO$$$Lambda$11062/0x00007f299be724c0@2a952d50 ,
810
810
// event = cats.effect.tracing.TracingEvent$StackTrace
811
811
// )
812
812
// ),
813
- // fs = cats.effect.std.Supervisor$$$Lambda$12500/0x00007f055c13f510@4c59cc06
813
+ // fs = cats.effect.std.Supervisor$$$Lambda$11750/0x00007f299c01d010@1cf94f9b
814
814
// ),
815
- // fs = cats.effect.kernel.Resource$$Lambda$12502/0x00007f055c140000@5e64c1f6
815
+ // fs = cats.effect.kernel.Resource$$Lambda$11752/0x00007f299c01d7b0@b928569
816
816
// ),
817
- // fs = cats.effect.std.Dispatcher$$$Lambda$12503/0x00007f055c1403d0@69ade18a
817
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11753/0x00007f299c01db80@3e2506e
818
818
// ),
819
- // fs = cats.effect.kernel.Resource$$Lambda$12502/0x00007f055c140000@6d2fae7b
819
+ // fs = cats.effect.kernel.Resource$$Lambda$11752/0x00007f299c01d7b0@1e12ef
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$11805/0x00007f055bf924c0@6f147624 ,
833
+ // thunk = cats.effect.IO$$$Lambda$11062/0x00007f299be724c0@56cd10e0 ,
834
834
// event = cats.effect.tracing.TracingEvent$StackTrace
835
835
// )
836
836
// ),
837
- // fs = cats.effect.std.Supervisor$$$Lambda$12500/0x00007f055c13f510@17877141
837
+ // fs = cats.effect.std.Supervisor$$$Lambda$11750/0x00007f299c01d010@49eb7e9d
838
838
// ),
839
- // fs = cats.effect.kernel.Resource$$Lambda$12502/0x00007f055c140000@1120638a
839
+ // fs = cats.effect.kernel.Resource$$Lambda$11752/0x00007f299c01d7b0@581b36ee
840
840
// ),
841
- // fs = cats.effect.std.Dispatcher$$$Lambda$12503/0x00007f055c1403d0@1ec4ba3
841
+ // fs = cats.effect.std.Dispatcher$$$Lambda$11753/0x00007f299c01db80@28e2ce68
842
842
// ),
843
- // fs = cats.effect.kernel.Resource$$Lambda$12502/0x00007f055c140000@4d05a8ec
843
+ // fs = cats.effect.kernel.Resource$$Lambda$11752/0x00007f299c01d7b0@16168184
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$11805/0x00007f055bf924c0@6f147624 ,
850
+ // thunk = cats.effect.IO$$$Lambda$11062/0x00007f299be724c0@56cd10e0 ,
851
851
// event = cats.effect.tracing.TracingEvent$StackTrace
852
852
// ),
853
- // f = cats.effect.kernel.Resource$$Lambda$12505/0x00007f055c141230@6124c574 ,
853
+ // f = cats.effect.kernel.Resource$$Lambda$11755/0x00007f299c01ebe0@41b0a4d ,
854
854
// event = cats.effect.tracing.TracingEvent$StackTrace
855
855
// )
856
856
```
0 commit comments