Fixed bug

packages/stores/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@holochain-open-dev/stores",
-  "version": "0.8.8",
+  "version": "0.8.9",
   "description": "Re-export of svelte/store, with additional utilities to build reusable holochain-open-dev modules",
   "author": "[email protected]",
   "main": "dist/index.js",

packages/stores/src/pipe.ts

@@ -27,7 +27,7 @@ function pipeStep<T, U>(
 
         if (!!v && (v as Readable<any>).subscribe) {
           return (v as Readable<any>).subscribe((value) => {
-            if ((value as AsyncStatus<U>).status) {
+            if (value !== undefined && (value as AsyncStatus<U>).status) {
               set(value);
             } else {
               set({ status: "complete", value });

packages/stores/tests/pipe.test.js

@@ -38,6 +38,23 @@ it("pipe with normal fn that returns undefined", async () => {
   });
 });
 
+it("pipe with readable fn that returns undefined", async () => {
+  const asyncReadableStore = asyncReadable(async (set) => {
+    await sleep(10);
+    set("hi");
+  });
+  const pipeStore = pipe(asyncReadableStore, (s) => readable(undefined));
+  const subscriber = pipeStore.subscribe(() => {});
+
+  expect(get(pipeStore)).to.deep.equal({ status: "pending" });
+  await sleep(20);
+
+  expect(get(pipeStore)).to.deep.equal({
+    status: "complete",
+    value: undefined,
+  });
+});
+
 it("pipe with promise", async () => {
   const asyncReadableStore = asyncReadable(async (set) => {
     await sleep(10);