fix: revert changes to server related components

Author: CodeWithKyrian

examples/server/client-communication/server.php

@@ -9,7 +9,7 @@
  * file that was distributed with this source code.
  */
 
-require_once dirname(__DIR__) . '/bootstrap.php';
+require_once dirname(__DIR__).'/bootstrap.php';
 chdir(__DIR__);
 
 use Mcp\Schema\Enum\LoggingLevel;
@@ -22,7 +22,7 @@
     ->setServerInfo('Client Communication Demo', '1.0.0')
     ->setLogger(logger())
     ->setContainer(container())
-    ->setSession(new FileSessionStore(__DIR__ . '/sessions'))
+    ->setSession(new FileSessionStore(__DIR__.'/sessions'))
     ->setCapabilities(new ServerCapabilities(logging: true, tools: true))
     ->setDiscovery(__DIR__)
     ->addTool(

src/Server/Transport/StdioTransport.php

@@ -105,15 +105,9 @@ private function processFiber(): void
         $pendingRequests = $this->getPendingRequests($this->sessionId);
 
         if (empty($pendingRequests)) {
-            // Flush any queued messages before resuming (e.g., notifications from previous yield)
-            $this->flushOutgoingMessages();
-
             $yielded = $this->sessionFiber->resume();
             $this->handleFiberYield($yielded, $this->sessionId);
 
-            // Flush newly queued messages (like notifications) before returning
-            $this->flushOutgoingMessages();
-
             return;
         }
 
@@ -127,7 +121,6 @@ private function processFiber(): void
             if (null !== $response) {
                 $yielded = $this->sessionFiber->resume($response);
                 $this->handleFiberYield($yielded, $this->sessionId);
-                $this->flushOutgoingMessages();
 
                 return;
             }
@@ -136,7 +129,6 @@ private function processFiber(): void
                 $error = Error::forInternalError('Request timed out', $requestId);
                 $yielded = $this->sessionFiber->resume($error);
                 $this->handleFiberYield($yielded, $this->sessionId);
-                $this->flushOutgoingMessages();
 
                 return;
             }
@@ -171,7 +163,6 @@ private function flushOutgoingMessages(): void
     private function writeLine(string $payload): void
     {
         fwrite($this->output, $payload . \PHP_EOL);
-        fflush($this->output);
     }
 
     public function close(): void