diff --git a/src/AppKernelAdapter.php b/src/AppKernelAdapter.php
new file mode 100644
index 0000000..c0c5703
--- /dev/null
+++ b/src/AppKernelAdapter.php
@@ -0,0 +1,106 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App;
+
+use App\Kernel as ApplicationKernel;
+use Drift\EventBus\Subscriber\EventBusSubscriber;
+use Drift\HttpKernel\AsyncKernel;
+use Drift\Server\Adapter\DriftKernel\SyncKernelException;
+use Drift\Server\Adapter\SymfonyKernelBasedAdapter;
+use Exception;
+use React\Promise\Promise;
+use React\Promise\PromiseInterface;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpKernel\Kernel;
+
+class AppKernelAdapter extends SymfonyKernelBasedAdapter
+{
+    /**
+     * @param $kernel
+     *
+     * @throws Exception|SyncKernelException
+     */
+    protected function checkKernel($kernel)
+    {
+        if (!$kernel instanceof AsyncKernel) {
+            throw new SyncKernelException('The kernel should implement AsyncKernel interface, as you are using the DriftPHP kernel adapter');
+        }
+    }
+
+    /**
+     * @param string $environment
+     * @param bool   $debug
+     *
+     * @return Kernel
+     */
+    protected static function createKernelByEnvironmentAndDebug(
+        string $environment,
+        bool $debug
+    ): Kernel {
+        return new ApplicationKernel($environment, $debug);
+    }
+
+    /**
+     * @return PromiseInterface
+     */
+    protected function preload(): PromiseInterface
+    {
+        return $this
+            ->kernel
+            ->preload()
+            ->then(function () {
+                $container = $this->kernel->getContainer();
+                $serverContext = $this->serverContext;
+
+                if (
+                    class_exists(EventBusSubscriber::class) &&
+                    $serverContext->hasExchanges() &&
+                    $container->has(EventBusSubscriber::class)
+                ) {
+                    $eventBusSubscriber = $container->get(EventBusSubscriber::class);
+                    $eventBusSubscriber->subscribeToExchanges(
+                        $serverContext->getExchanges(),
+                        $this->outputPrinter
+                    );
+                }
+            });
+    }
+
+    /**
+     * @param Kernel|AsyncKernel $kernel
+     * @param Request            $request
+     *
+     * @return PromiseInterface
+     */
+    protected function kernelHandle(
+        Kernel $kernel,
+        Request $request
+    ): PromiseInterface {
+        return $kernel->handleAsync($request);
+    }
+
+    /**
+     * @return PromiseInterface
+     */
+    public function shutDown(): PromiseInterface
+    {
+        $resolver = function (callable $resolve, callable $reject) {
+            $this->kernel->shutdown();
+            $resolve();
+        };
+
+        return new Promise($resolver);
+    }
+
+    /**
+     * Get watcher folders.
+     *
+     * @return string[]
+     */
+    public static function getObservableFolders(): array
+    {
+        return ['src', 'public', 'views'];
+    }
+}