Skip to content

Commit

Permalink
deploy: 3aef78e
Browse files Browse the repository at this point in the history
  • Loading branch information
mpilquist committed Oct 6, 2024
1 parent c84dbd9 commit 06e1549
Showing 1 changed file with 19 additions and 19 deletions.
38 changes: 19 additions & 19 deletions guide.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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()
Expand Down Expand Up @@ -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
// )
```

Expand All @@ -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
// )
```
Expand Down

0 comments on commit 06e1549

Please sign in to comment.