diff --git a/src/Server/Protocol/ProtocolHandlerInterface.php b/src/Server/Protocol/ProtocolHandlerInterface.php
new file mode 100644
index 0000000..92830dd
--- /dev/null
+++ b/src/Server/Protocol/ProtocolHandlerInterface.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CrazyGoat\Forklift\Server\Protocol;
+
+use CrazyGoat\Forklift\Server\Socket\Connection;
+
+interface ProtocolHandlerInterface
+{
+    public function handle(Connection $connection): void;
+}
diff --git a/src/Server/Protocol/TcpHandler.php b/src/Server/Protocol/TcpHandler.php
new file mode 100644
index 0000000..37dd59b
--- /dev/null
+++ b/src/Server/Protocol/TcpHandler.php
@@ -0,0 +1,23 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CrazyGoat\Forklift\Server\Protocol;
+
+use CrazyGoat\Forklift\Server\Socket\Connection;
+
+class TcpHandler implements ProtocolHandlerInterface
+{
+    public function __construct(
+        /** @var \Closure(Connection): void|null */
+        private readonly ?\Closure $callback = null,
+    ) {
+    }
+
+    public function handle(Connection $connection): void
+    {
+        if ($this->callback instanceof \Closure) {
+            ($this->callback)($connection);
+        }
+    }
+}
diff --git a/tests/Server/Protocol/TcpHandlerTest.php b/tests/Server/Protocol/TcpHandlerTest.php
new file mode 100644
index 0000000..19620d8
--- /dev/null
+++ b/tests/Server/Protocol/TcpHandlerTest.php
@@ -0,0 +1,67 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CrazyGoat\Forklift\Tests\Server\Protocol;
+
+use CrazyGoat\Forklift\Server\Protocol\TcpHandler;
+use CrazyGoat\Forklift\Server\Socket\Connection;
+use PHPUnit\Framework\TestCase;
+
+class TcpHandlerTest extends TestCase
+{
+    public function testNoCallbackIsNoOp(): void
+    {
+        $socket = \socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+        $this->assertNotFalse($socket);
+
+        $connection = new Connection($socket);
+        $handler = new TcpHandler();
+
+        $handler->handle($connection);
+
+        $this->assertFalse($connection->isClosed());
+
+        $connection->close();
+    }
+
+    public function testCallbackIsCalledWithConnection(): void
+    {
+        $socket = \socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+        $this->assertNotFalse($socket);
+
+        $connection = new Connection($socket);
+
+        $called = false;
+        $passedConnection = null;
+
+        $handler = new TcpHandler(function (Connection $conn) use (&$called, &$passedConnection): void {
+            $called = true;
+            $passedConnection = $conn;
+        });
+
+        $handler->handle($connection);
+
+        $this->assertTrue($called);
+        $this->assertSame($connection, $passedConnection);
+
+        $connection->close();
+    }
+
+    public function testHandlerDoesNotCloseConnection(): void
+    {
+        $socket = \socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+        $this->assertNotFalse($socket);
+
+        $connection = new Connection($socket);
+
+        $handler = new TcpHandler(function (Connection $conn): void {
+        });
+
+        $handler->handle($connection);
+
+        $this->assertFalse($connection->isClosed());
+
+        $connection->close();
+    }
+}