diff --git a/src/pages/market/Track.vue b/src/pages/market/Track.vue
index 8a24726..1f8f177 100644
--- a/src/pages/market/Track.vue
+++ b/src/pages/market/Track.vue
@@ -21,7 +21,7 @@ watch(() => trackedItemStore.items.value, async itms => {
         
         return { ...i, ...price };
     });
-})
+}, { immediate: true })
 
 </script>
 
diff --git a/src/pocketbase/collection.ts b/src/pocketbase/collection.ts
index 0b5b57d..c99c6fd 100644
--- a/src/pocketbase/collection.ts
+++ b/src/pocketbase/collection.ts
@@ -1,16 +1,12 @@
 
 import { usePocketBase } from "@/pocketbase";
-import { RecordModel, RecordSubscription, UnsubscribeFunc } from "pocketbase";
-import { Ref, computed, onMounted, onUnmounted, ref } from "vue";
+import { RecordModel, RecordSubscription } from "pocketbase";
+import { Ref, computed, onMounted, ref } from "vue";
 
-export const watchCollection = <T extends RecordModel = RecordModel>(collection: string, query: string, callback: (data: RecordSubscription<T>) => void) => {
+export const watchCollection = <T extends RecordModel = RecordModel>(collection: string, topic: string, callback: (data: RecordSubscription<T>) => void) => {
     const pb = usePocketBase();
-    let unsubscribe: UnsubscribeFunc = () => Promise.resolve();
 
-    onMounted(async () => {
-        unsubscribe = await pb.collection(collection).subscribe<T>(query, callback);
-    });
-    onUnmounted(() => unsubscribe());
+    onMounted(async () => await pb.collection(collection).subscribe<T>(topic, callback));
 };
 
 export const useCollection = <T extends RecordModel = RecordModel>(collection: string) => {