Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
adamw authored Feb 19, 2024
1 parent 8a93132 commit 80322e9
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -515,10 +515,9 @@ To run multiple transformations within one virtual thread / fork, the `.transfor

```scala
import ox.supervised
import ox.channels.{Channel, Source}
import ox.channels.Source

supervised {
val c = Channel[Int]()
fork {
Source.iterate(0)(_ + 1) // natural numbers
.transform(_.filter(_ % 2 == 0).map(_ + 1).take(10)) // take the 10 first even numbers, incremented by 1
Expand Down

0 comments on commit 80322e9

Please # to comment.