From 06e154969fcbb195d3fb4247a840420f54787e65 Mon Sep 17 00:00:00 2001 From: mpilquist Date: Sun, 6 Oct 2024 13:33:34 +0000 Subject: [PATCH] deploy: 3aef78ea8cf0dd5d190f316fcfc53ba7612bb2c5 --- guide.md | 38 +++++++++++++++++++------------------- 1 file changed, 19 insertions(+), 19 deletions(-) diff --git a/guide.md b/guide.md index 68a5611a01..4a56a4a376 100644 --- a/guide.md +++ b/guide.md @@ -718,10 +718,10 @@ val program = // program: Stream[[x]IO[x], Unit] = Stream(..) program.compile.drain.unsafeRunSync() -// 13:27:59.568821291 -// 13:28:00.568806303 -// 13:28:01.568572824 -// 13:28:02.568582956 +// 13:33:19.472094942 +// 13:33:20.472164629 +// 13:33:21.472189224 +// 13:33:22.472096957 ``` Let's take this line by line now, so we can understand what's going on. @@ -763,10 +763,10 @@ val program1 = // program1: Stream[[x]IO[x], Unit] = Stream(..) program1.compile.drain.unsafeRunSync() -// 13:28:04.571116028 -// 13:28:05.571187514 -// 13:28:06.571136433 -// 13:28:07.571169558 +// 13:33:24.474974914 +// 13:33:25.475021079 +// 13:33:26.475095623 +// 13:33:27.475040930 ``` ### Talking to the external world @@ -799,7 +799,7 @@ The way you bring synchronous effects into your effect type may differ. `Sync.de import cats.effect.Sync val T = Sync[IO] -// T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@3855c43e +// T: cats.effect.kernel.Async[IO] = cats.effect.IO$$anon$5@57c3fb88 val s2 = Stream.exec(T.delay { destroyUniverse() }) ++ Stream("...moving on") // s2: Stream[[x]IO[x], String] = Stream(..) s2.compile.toVector.unsafeRunSync() @@ -933,15 +933,15 @@ stream.toUnicastPublisher // source = Bind( // source = Eval( // fa = Delay( -// thunk = cats.effect.IO$$$Lambda$11300/0x00007f2767ed14c0@4984bb0b, +// thunk = cats.effect.IO$$$Lambda$11185/0x00007fd3efe902c0@4a123fd1, // event = cats.effect.tracing.TracingEvent$StackTrace // ) // ), -// fs = cats.effect.std.Supervisor$$$Lambda$12217/0x00007f27680d1638@20d762ed +// fs = cats.effect.std.Supervisor$$$Lambda$12106/0x00007fd3f00983d0@34f95a43 // ), -// fs = cats.effect.std.Dispatcher$$$Lambda$12218/0x00007f27680d1a08@568d472f +// fs = cats.effect.std.Dispatcher$$$Lambda$12107/0x00007fd3f00987a0@53695208 // ), -// fs = cats.effect.kernel.Resource$$Lambda$12061/0x00007f276809f190@704b78b7 +// fs = cats.effect.kernel.Resource$$Lambda$11948/0x00007fd3f0052678@710b7187 // ) ``` @@ -954,25 +954,25 @@ val publisher: Resource[IO, StreamUnicastPublisher[IO, Int]] = Stream(1, 2, 3).c // source = Bind( // source = Eval( // fa = Delay( -// thunk = cats.effect.IO$$$Lambda$11300/0x00007f2767ed14c0@1c7bd956, +// thunk = cats.effect.IO$$$Lambda$11185/0x00007fd3efe902c0@2abc24c0, // event = cats.effect.tracing.TracingEvent$StackTrace // ) // ), -// fs = cats.effect.std.Supervisor$$$Lambda$12217/0x00007f27680d1638@720003e +// fs = cats.effect.std.Supervisor$$$Lambda$12106/0x00007fd3f00983d0@54694896 // ), -// fs = cats.effect.std.Dispatcher$$$Lambda$12218/0x00007f27680d1a08@3b288bca +// fs = cats.effect.std.Dispatcher$$$Lambda$12107/0x00007fd3f00987a0@4d09b901 // ), -// fs = cats.effect.kernel.Resource$$Lambda$12061/0x00007f276809f190@100dd2d8 +// fs = cats.effect.kernel.Resource$$Lambda$11948/0x00007fd3f0052678@67a47e6e // ) publisher.use { p => p.toStream[IO].compile.toList } // res59: IO[List[Int]] = FlatMap( // ioe = Delay( -// thunk = cats.effect.IO$$$Lambda$11300/0x00007f2767ed14c0@1c7bd956, +// thunk = cats.effect.IO$$$Lambda$11185/0x00007fd3efe902c0@2abc24c0, // event = cats.effect.tracing.TracingEvent$StackTrace // ), -// f = cats.effect.kernel.Resource$$Lambda$12220/0x00007f27680d2e68@3a1636d1, +// f = cats.effect.kernel.Resource$$Lambda$12109/0x00007fd3f0099c00@586acf85, // event = cats.effect.tracing.TracingEvent$StackTrace // ) ```