Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Use jox for channels #63

Merged
merged 2 commits into from
Jan 25, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 4 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ Safe direct-style concurrency and resiliency for Scala on the JVM, based on:
* [Project Loom](https://openjdk.org/projects/loom/) (virtual threads)
* structured concurrency Java APIs ([JEP 428](https://openjdk.org/jeps/428))
* scoped values ([JEP 429](https://openjdk.org/jeps/429))
* [Go](https://golang.org)-like channels
* fast, scalable [Go](https://golang.org)-like channels using [jox](https://github.com/softwaremill/jox)
* the [Scala 3](https://www.scala-lang.org) programming language

Requires JDK 21.
Expand Down Expand Up @@ -421,7 +421,7 @@ import ox.channels.*
val c = Channel[String](5)
```

Unbounded channels can be created by providing a capacity of `Int.MaxValue`.
Unbounded channels can be created using `Channel.unlimited[T]`.

Channels implement two traits: `Source` and `Sink`.

Expand Down Expand Up @@ -803,6 +803,7 @@ supervised {

How we use various terms throughout the codebase (or at least try to):

* **concurrency scope**: either `supervised` (default) or `scoped` ("advanced")
* a scope **ends**: when unsupervised, the main code block is entirely evaluated; when supervised, all non-daemon,
supervised forks completed successfully, or at least one supervised fork failed. When the scope ends, all running
forks are interrupted
Expand Down Expand Up @@ -832,4 +833,4 @@ We offer commercial development services. [Contact us](https://softwaremill.com)

## Copyright

Copyright (C) 2023 SoftwareMill [https://softwaremill.com](https://softwaremill.com).
Copyright (C) 2023-2024 SoftwareMill [https://softwaremill.com](https://softwaremill.com).
3 changes: 2 additions & 1 deletion build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ lazy val commonSettings = commonSmlBuildSettings ++ ossPublishSettings ++ Seq(

val scalaTest = "org.scalatest" %% "scalatest" % "3.2.15" % Test
val slf4j = "org.slf4j" % "slf4j-api" % "2.0.7"
val logback = "ch.qos.logback" % "logback-classic" % "1.4.7"
val logback = "ch.qos.logback" % "logback-classic" % "1.4.12"

lazy val rootProject = (project in file("."))
.settings(commonSettings)
Expand All @@ -20,6 +20,7 @@ lazy val core: Project = (project in file("core"))
.settings(
name := "core",
libraryDependencies ++= Seq(
"com.softwaremill.jox" % "core" % "0.0.6",
scalaTest
)
)
Expand Down
69 changes: 0 additions & 69 deletions core/src/main/scala/ox/channels/Cell.scala

This file was deleted.

Loading
Loading