fix(content): getContentFile stream should be finished (#1110)

packages/content/src/lib/content.spec.ts

@@ -221,6 +221,48 @@ Test agx Content`),
     flush();
   }));
 
+  it('should finish the stream when content is resolved', fakeAsync(() => {
+    const routeParams = {};
+    const contentFiles = {
+      '/src/content/test.md': () =>
+        Promise.resolve(`---
+slug: 'test'
+---
+Test Content`),
+    };
+    const { injectContent } = setup({
+      routeParams,
+      contentFiles,
+      customParam: {
+        customFilename: 'test',
+      },
+    });
+
+    let completed = false;
+    let content: ContentFile<TestAttributes | Record<string, never>> | null =
+      null;
+
+    injectContent().subscribe({
+      next: (c) => {
+        content = c;
+      },
+      complete: () => {
+        completed = true;
+      },
+    });
+
+    flushMicrotasks();
+    flush();
+
+    expect(completed).toBe(true);
+    expect(content).toEqual({
+      content: 'Test Content',
+      attributes: { slug: 'test' },
+      filename: '/src/content/test',
+      slug: 'test',
+    });
+  }));
+
   function setup(
     args: Partial<{
       customParam:

packages/content/src/lib/content.ts

@@ -38,10 +38,12 @@ function getContentFile<
       if (import.meta.env.SSR === true) {
         waitFor(contentResolver).then((content) => {
           observer.next(content);
+          observer.complete();
         });
       } else {
         contentResolver.then((content) => {
           observer.next(content);
+          observer.complete();
         });
       }
     }