Refresh onto JSR (#3)

* Remove Deno specific imports, publish to JSR

* Update README

* Update version and readme more

* Update for outdated type reference

* Ok looks like we're looking forward towards Deno 2.0

.github/workflows/deno-ci.yml

@@ -13,8 +13,7 @@ jobs:
     strategy:
       matrix:
         deno-version:
-        - v1.20
-        - v1.25
+        - v1.45
         - canary
       fail-fast: false # run each branch to completion
 

.github/workflows/jsr-publish.yaml

@@ -0,0 +1,19 @@
+name: Publish
+on:
+  push:
+    branches:
+      - main
+    paths:
+      - src/jsr.json
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+
+    permissions:
+      contents: read
+      id-token: write
+
+    steps:
+      - uses: actions/checkout@v4
+      - run: npx jsr publish

README.md

@@ -0,0 +1 @@
+src/README.md

src/README.md

@@ -1,6 +1,12 @@
 This module is a Deno-friendly port
 of [observables-with-streams](https://github.com/surma/observables-with-streams).
 
+Published to `jsr.io` as `@cloudydeno/stream-observables`.
+Read more about [using packages](https://jsr.io/docs/using-packages).
+
+Published to `/x/` as `stream_observables`.
+Import from `https://deno.land/x/[email protected]/`.
+
 Subset of original README below:
 
 # Observables with Streams
@@ -14,7 +20,7 @@ The goal of this library is to implement observables making as much use of the p
 ## Example
 
 ```typescript
-import * as ows from "https://deno.land/x/stream_observables/mod.ts";
+import * as ows from "jsr:@cloudydeno/stream-observables@^1.4.0";
 
 console.log('Tap Enter to add energy!');
 ows.merge(

src/jsr.json

@@ -0,0 +1,5 @@
+{
+  "name": "@cloudydeno/stream-observables",
+  "version": "1.4.0",
+  "exports": "./mod.ts"
+}

src/sources/external.ts

@@ -25,7 +25,7 @@ export type NextFunc<T> = (v: T | typeof EOF) => void;
  *
  * @typeparam T Type of items to be emitted by the observable.
  */
-export function external<T>(cancel?: ReadableStreamErrorCallback) {
+export function external<T>(cancel?: UnderlyingSourceCancelCallback) {
   let next: NextFunc<T>;
   const observable = new ReadableStream<T>(
     {

src/sources/from-iterable.ts

@@ -1,3 +1 @@
-export {
-  readableStreamFromIterable as fromIterable,
-} from "https://deno.land/[email protected]/streams/readable_stream_from_iterable.ts";
+export const fromIterable = ReadableStream.from;

src/sources/mod.ts

@@ -13,7 +13,6 @@
 
 export * from "./external.ts";
 export * from "./from-async-function.ts";
-export * from "./from-deno-reader.ts";
 export * from "./from-event.ts";
 export * from "./from-generator.ts";
 export * from "./from-iterable.ts";