chore(release): 0.0.1

CHANGELOG.md

@@ -6,11 +6,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
-## [0.0.2] - 2025-07-01
-
-### Docs
-- correct
-
 ## [0.0.1] - 2025-07-01
 
 ### Added

Cargo.toml

@@ -3,7 +3,7 @@ members = ["crates/*"]
 resolver = "2"
 
 [workspace.package]
-version = "0.0.2"
+version = "0.0.1"
 
 [workspace.dependencies]
 noworkers = { path = "crates/noworkers" }

README.md

@@ -25,39 +25,33 @@ Then in your code:
 
 ```rust
 use noworkers::Workers;
+use tokio_util::sync::CancellationToken;
 ```
 
 ## Quick Example
 
-```rust
+```rust,no_run
 use noworkers::Workers;
+use tokio_util::sync::CancellationToken;
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
     // Create a worker group with up to 5 concurrent tasks
     let mut workers = Workers::new();
 
-    // Limit amount of concurrent workers
-    workers.with_limit(5);
-
-    // Adds cancellation signal
-    workers.with_cancel_task(async move {
-      // send cancellation to tasks after 60 seconds
-      tokio::time::sleep(std::time::Duration::from_secs(60)).await
-    });
+    workers
+        .with_limit(5)
+        .with_cancel(&CancellationToken::new());
 
     // Spawn 10 async jobs
     for i in 0..10 {
-        // Work is done immediatley, so this will wait in two batches of 1 seconds each (because of limit)
         workers.add(move |cancel_token| async move {
-            // optional tokio::select, if you use cancellation for your tasks, if not just do your work
+            // Respect cancellation, or not, if you don't care about blocking forever
             tokio::select! {
-                // Do work, in this case just sleep
                 _ = tokio::time::sleep(tokio::time::Duration::from_secs(1)) => {
                     println!("Job {i} done");
                     Ok(())
                 }
-                // If we receive cancel we close
                 _ = cancel_token.cancelled() => {
                     println!("Job {i} cancelled");
                     Ok(())