diff --git a/examples/react/todo/src/lib/collections.ts b/examples/react/todo/src/lib/collections.ts
index 689372b80..e8154c5a2 100644
--- a/examples/react/todo/src/lib/collections.ts
+++ b/examples/react/todo/src/lib/collections.ts
@@ -132,7 +132,6 @@ export const trailBaseTodoCollection = createCollection(
   trailBaseCollectionOptions<SelectTodo, Todo>({
     id: `todos`,
     getKey: (item) => item.id,
-    schema: selectTodoSchema,
     recordApi: trailBaseClient.records(`todos`),
     // Re-using the example's drizzle-schema requires remapping the items.
     parse: {
@@ -233,7 +232,6 @@ export const trailBaseConfigCollection = createCollection(
   trailBaseCollectionOptions<SelectConfig, Config>({
     id: `config`,
     getKey: (item) => item.id,
-    schema: selectConfigSchema,
     recordApi: trailBaseClient.records(`config`),
     // Re-using the example's drizzle-schema requires remapping the items.
     parse: {
diff --git a/examples/solid/todo/src/lib/collections.ts b/examples/solid/todo/src/lib/collections.ts
index fa7ce9530..e252809e5 100644
--- a/examples/solid/todo/src/lib/collections.ts
+++ b/examples/solid/todo/src/lib/collections.ts
@@ -120,7 +120,6 @@ export const trailBaseTodoCollection = createCollection(
   trailBaseCollectionOptions<SelectTodo, Todo>({
     id: `todos`,
     getKey: (item) => item.id,
-    schema: selectTodoSchema,
     recordApi: trailBaseClient.records(`todos`),
     // Re-using the example's drizzle-schema requires remapping the items.
     parse: {
@@ -215,7 +214,6 @@ export const trailBaseConfigCollection = createCollection(
   trailBaseCollectionOptions<SelectConfig, Config>({
     id: `config`,
     getKey: (item) => item.id,
-    schema: selectConfigSchema,
     recordApi: trailBaseClient.records(`config`),
     // Re-using the example's drizzle-schema requires remapping the items.
     parse: {
diff --git a/packages/trailbase-db-collection/tests/trailbase.test.ts b/packages/trailbase-db-collection/tests/trailbase.test.ts
index a6d282a30..f59605394 100644
--- a/packages/trailbase-db-collection/tests/trailbase.test.ts
+++ b/packages/trailbase-db-collection/tests/trailbase.test.ts
@@ -2,11 +2,20 @@ import { describe, expect, it, vi } from 'vitest'
 import { createCollection } from '@tanstack/db'
 import { trailBaseCollectionOptions } from '../src/trailbase'
 import type {
+  CreateOperation,
+  DeleteOperation,
   Event,
   FilterOrComposite,
+  ListOperation,
+  ListOpts,
   ListResponse,
   Pagination,
+  ReadOperation,
+  ReadOpts,
   RecordApi,
+  RecordId,
+  SubscribeOpts,
+  UpdateOperation,
 } from 'trailbase'
 
 type Data = {
@@ -27,6 +36,9 @@ class MockRecordApi<T> implements RecordApi<T> {
       return Promise.resolve({ records: [] })
     },
   )
+  listOp = vi.fn((_opts?: ListOpts): ListOperation<T> => {
+    throw `listOp`
+  })
 
   read = vi.fn(
     (
@@ -38,6 +50,9 @@ class MockRecordApi<T> implements RecordApi<T> {
       throw `read`
     },
   )
+  readOp = vi.fn((_id: RecordId, _opt?: ReadOpts): ReadOperation<T> => {
+    throw `readOp`
+  })
 
   create = vi.fn((_record: T): Promise<string | number> => {
     throw `create`
@@ -45,13 +60,24 @@ class MockRecordApi<T> implements RecordApi<T> {
   createBulk = vi.fn((_records: Array<T>): Promise<Array<string | number>> => {
     throw `createBulk`
   })
+  createOp = vi.fn((_record: T): CreateOperation<T> => {
+    throw `createOp`
+  })
 
   update = vi.fn((_id: string | number, _record: Partial<T>): Promise<void> => {
     throw `update`
   })
+  updateOp = vi.fn((_id: RecordId, _record: Partial<T>): UpdateOperation => {
+    throw `updateOp`
+  })
+
   delete = vi.fn((_id: string | number): Promise<void> => {
     throw `delete`
   })
+  deleteOp = vi.fn((_id: RecordId): DeleteOperation => {
+    throw `deleteOp`
+  })
+
   subscribe = vi.fn((_id: string | number): Promise<ReadableStream<Event>> => {
     return Promise.resolve(
       new ReadableStream({
@@ -61,6 +87,11 @@ class MockRecordApi<T> implements RecordApi<T> {
       }),
     )
   })
+  subscribeAll = vi.fn(
+    (_opts?: SubscribeOpts): Promise<ReadableStream<Event>> => {
+      throw `subscribeAll`
+    },
+  )
 }
 
 function setUp(recordApi: MockRecordApi<Data>) {