Fixed bug

packages/stores/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@holochain-open-dev/stores",
-  "version": "0.8.4",
+  "version": "0.8.5",
   "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

@@ -25,7 +25,7 @@ function pipeStep<T, U>(
             .reverse()
         );
 
-        if ((v as Readable<any>).subscribe) {
+        if (!!v && (v as Readable<any>).subscribe) {
           return (v as Readable<any>).subscribe((value) => {
             if ((value as AsyncStatus<U>).status) {
               set(value);

packages/stores/tests/pipe.test.js

@@ -21,6 +21,23 @@ it("pipe with normal fn", async () => {
   });
 });
 
+it("pipe with normal fn that returns undefined", async () => {
+  const asyncReadableStore = asyncReadable(async (set) => {
+    await sleep(10);
+    set("hi");
+  });
+  const pipeStore = pipe(asyncReadableStore, (s) => 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);