<?php

declare(strict_types=1);

namespace Psalm\Tests\LanguageServer;

use Psalm\Internal\LanguageServer\EmitterInterface;
use Psalm\Internal\LanguageServer\EmitterTrait;
use Psalm\Internal\LanguageServer\Message;
use Psalm\Internal\LanguageServer\ProtocolReader;
use Psalm\Internal\LanguageServer\ProtocolWriter;
use Revolt\EventLoop;

/**
 * A fake duplex protocol stream
 */
class MockProtocolStream implements ProtocolReader, ProtocolWriter, EmitterInterface
{
    use EmitterTrait;
    /**
     * Sends a Message to the client
     */
    public function write(Message $msg): void
    {
        EventLoop::queue(function () use ($msg): void {
            $this->emit('message', [Message::parse((string)$msg)]);
        });
    }
}