diff --git a/src/pipeline.test.ts b/src/pipeline.test.ts
new file mode 100644
index 0000000..f046ef2
--- /dev/null
+++ b/src/pipeline.test.ts
@@ -0,0 +1,42 @@
+import { assertEquals } from './deps.ts';
+
+import pipeline from './pipeline.ts';
+import noopPolicy from './policies/noop-policy.ts';
+import readOnlyPolicy from './policies/read-only-policy.ts';
+import { buildInputMessage } from './test.ts';
+
+Deno.test('passes events through multiple policies', async () => {
+  const msg = buildInputMessage();
+
+  const result = await pipeline(msg, [
+    noopPolicy,
+    readOnlyPolicy,
+  ]);
+
+  assertEquals(result.action, 'reject');
+  assertEquals(result.msg, 'The relay is read-only.');
+});
+
+Deno.test('short-circuits on the first reject', async () => {
+  const msg = buildInputMessage();
+
+  const result = await pipeline(msg, [
+    readOnlyPolicy,
+    noopPolicy,
+  ]);
+
+  assertEquals(result.action, 'reject');
+  assertEquals(result.msg, 'The relay is read-only.');
+});
+
+Deno.test('accepts when all policies accept', async () => {
+  const msg = buildInputMessage();
+
+  const result = await pipeline(msg, [
+    noopPolicy,
+    noopPolicy,
+    noopPolicy,
+  ]);
+
+  assertEquals(result.action, 'accept');
+});