*/ final class UnboundedSender implements SenderInterface { /** * @use ChannelSideTrait> */ use ChannelSideTrait; /** * @param UnboundedChannelState $state */ public function __construct(UnboundedChannelState $state) { $this->state = $state; } /** * {@inheritDoc} */ public function send(mixed $message): void { /** @psalm-suppress MissingThrowsDocblock */ $this->state->send($message); } /** * {@inheritDoc} */ public function trySend(mixed $message): void { $this->state->send($message); } }