chore: release 1.1.0

Author: MeirionHughes

docs/utilities.md

@@ -155,98 +155,3 @@ Available TransformStream classes include:
 - All timing operators: `DelayTransform`, `DebounceTimeTransform`, `ThrottleTimeTransform`, etc.
 - All flattening operators: `MergeMapTransform`, `SwitchMapTransform`, `ConcatMapTransform`, etc.
 - All utility operators: `TapTransform`, `CatchErrorTransform`, `TakeTransform`, etc.
-
-## Type Utilities
-
-### `isReadableStream()`
-
-Type guard to check if an object is a `ReadableStream`.
-
-```typescript
-import { isReadableStream } from 'web-streams-extensions';
-
-if (isReadableStream(obj)) {
-  // obj is guaranteed to be ReadableStream
-  const reader = obj.getReader();
-}
-```
-
-### `isTransform()`
-
-Type guard to check if an operator is a `TransformStream`.
-
-```typescript
-import { isTransform } from 'web-streams-extensions';
-
-if (isTransform(op)) {
-  // op is a TransformStream, can use with pipeThrough
-  stream.pipeThrough(op);
-} else {
-  // op is a function, use with pipe
-  stream.pipe(op);
-}
-```
-
-## Async Utilities
-
-### `sleep()`
-
-Returns a Promise that resolves after a specified duration.
-
-```typescript
-import { sleep } from 'web-streams-extensions';
-
-// Wait for 1 second
-await sleep(1000);
-```
-
-### `Signal`
-
-A simple event signaling mechanism for coordination between async operations.
-
-```typescript
-import { Signal } from 'web-streams-extensions';
-
-const signal = new Signal();
-
-// Wait for signal
-await signal.wait();
-
-// Trigger the signal from elsewhere
-signal.fire();
-```
-
-### `Gate`
-
-A reusable async gate that can be opened and closed multiple times.
-
-```typescript
-import { Gate } from 'web-streams-extensions';
-
-const gate = new Gate();
-
-// Close the gate
-gate.close();
-
-// Wait for gate to open
-await gate.wait();
-
-// Open the gate
-gate.open();
-```
-
-### `BlockingQueue<T>`
-
-An async queue that blocks when empty.
-
-```typescript
-import { BlockingQueue } from 'web-streams-extensions';
-
-const queue = new BlockingQueue<number>();
-
-// This will block until something is added
-const item = await queue.dequeue();
-
-// Add items from another context
-queue.enqueue(42);
-```

package.json

@@ -1,6 +1,6 @@
 {
   "name": "web-streams-extensions",
-  "version": "1.0.0",
+  "version": "1.1.0",
   "description": "A comprehensive collection of helper methods for WebStreams with built-in backpressure support, inspired by ReactiveExtensions",
   "type": "module",
   "types": "./dist/esm/index.d.ts",