1: <?php
2:
3: declare(strict_types=1);
4:
5: /**
6: * This file is part of the Nexus MCP SDK package.
7: *
8: * (c) 2026 John Paul E. Balandan, CPA <paulbalandan@gmail.com>
9: *
10: * For the full copyright and license information, please view
11: * the LICENSE file that was distributed with this source code.
12: */
13:
14: namespace Nexus\Mcp\Client\Exception;
15:
16: use Nexus\Mcp\Core\Exception\McpExceptionInterface;
17: use Nexus\Mcp\Core\Schema\RequestId;
18:
19: /**
20: * Thrown when a subscription stream the caller already closed is awaited.
21: */
22: final class SubscriptionClosedException extends \LogicException implements McpExceptionInterface
23: {
24: public function __construct(public readonly RequestId $subscriptionId, ?\Throwable $previous = null)
25: {
26: parent::__construct(
27: \sprintf('Subscription %s was closed by this client, so it carries no response to await.', var_export($subscriptionId->id, true)),
28: previous: $previous,
29: );
30: }
31: }
32: