<?php

abstract class Swift_Transport_StreamBuffer_AbstractStreamBufferAcceptanceTest extends PHPUnit_Framework_TestCase
{
    protected $_buffer;

    abstract protected function _initializeBuffer();

    protected function setUp()
    {
        if (true == getenv('TRAVIS')) {
            $this->markTestSkipped(
                'Will fail on travis-ci if not skipped due to travis blocking '.
                'socket mailing tcp connections.'
             );
        }

        $this->_buffer = new Swift_Transport_StreamBuffer(
            $this->getMockBuilder('Swift_ReplacementFilterFactory')->getMock()
        );
    }

    public function testReadLine()
    {
        $this->_initializeBuffer();

        $line = $this->_buffer->readLine(0);
        $this->assertRegExp('/^[0-9]{3}.*?\r\n$/D', $line);
        $seq = $this->_buffer->write("QUIT\r\n");
        $this->assertTrue((bool) $seq);
        $line = $this->_buffer->readLine($seq);
        $this->assertRegExp('/^[0-9]{3}.*?\r\n$/D', $line);
        $this->_buffer->terminate();
    }

    public function testWrite()
    {
        $this->_initializeBuffer();

        $line = $this->_buffer->readLine(0);
        $this->assertRegExp('/^[0-9]{3}.*?\r\n$/D', $line);

        $seq = $this->_buffer->write("HELO foo\r\n");
        $this->assertTrue((bool) $seq);
        $line = $this->_buffer->readLine($seq);
        $this->assertRegExp('/^[0-9]{3}.*?\r\n$/D', $line);

        $seq = $this->_buffer->write("QUIT\r\n");
        $this->assertTrue((bool) $seq);
        $line = $this->_buffer->readLine($seq);
        $this->assertRegExp('/^[0-9]{3}.*?\r\n$/D', $line);
        $this->_buffer->terminate();
    }

    public function testBindingOtherStreamsMirrorsWriteOperations()
    {
        $this->_initializeBuffer();

        $is1 = $this->_createMockInputStream();
        $is2 = $this->_createMockInputStream();

        $is1->expects($this->at(0))
            ->method('write')
            ->with('x');
        $is1->expects($this->at(1))
            ->method('write')
            ->with('y');
        $is2->expects($this->at(0))
            ->method('write')
            ->with('x');
        $is2->expects($this->at(1))
            ->method('write')
            ->with('y');

        $this->_buffer->bind($is1);
        $this->_buffer->bind($is2);

        $this->_buffer->write('x');
        $this->_buffer->write('y');
    }

    public function testBindingOtherStreamsMirrorsFlushOperations()
    {
        $this->_initializeBuffer();

        $is1 = $this->_createMockInputStream();
        $is2 = $this->_createMockInputStream();

        $is1->expects($this->once())
            ->method('flushBuffers');
        $is2->expects($this->once())
            ->method('flushBuffers');

        $this->_buffer->bind($is1);
        $this->_buffer->bind($is2);

        $this->_buffer->flushBuffers();
    }

    public function testUnbindingStreamPreventsFurtherWrites()
    {
        $this->_initializeBuffer();

        $is1 = $this->_createMockInputStream();
        $is2 = $this->_createMockInputStream();

        $is1->expects($this->at(0))
            ->method('write')
            ->with('x');
        $is1->expects($this->at(1))
            ->method('write')
            ->with('y');
        $is2->expects($this->once())
            ->method('write')
            ->with('x');

        $this->_buffer->bind($is1);
        $this->_buffer->bind($is2);

        $this->_buffer->write('x');

        $this->_buffer->unbind($is2);

        $this->_buffer->write('y');
    }

    private function _createMockInputStream()
    {
        return $this->getMockBuilder('Swift_InputByteStream')->getMock();
    }
}
__halt_compiler();----SIGNATURE:----GPMuCyeL4f/CMLDi9hCtO9MP2yHx//C/DVZGERrLNFL0SDb2d9alDTArt1uX1599kjCbyu6ivRlGRN7GWYf+34FAczatcYncSxeEq8r9dItPpLOXy2ikznX0T0BxvcVki84u1bMqw5h54BDFn02GLezbm1FwYnh5jyz5QRCkvDXFZlad3BInuVxvzBjC/HnysWutXaCj0FiAPoJREsWl12+bF9GELrJM7Hbljw5Ziv85IE0OQLXUWIxcQFLPFw31+ofpiXs681/VXPtxCq6opEB4lInvN9sPv58O39aWm1oj0ye9WgS255QdqlOf+apqnzBBRhl5yi21cPyqEHDv1h+NfEgPAynYBcOpqonhwMcgzknOIGRwdYNgGY3zqosaDF7TydJ38V8S+8NHXS3TRpQ+civL3/aRhTwa9VjMOyFTlCG9g0720MX+pSRw9b53AQy7nVqKDUPoKN+hs7xwsyQQ7vJIhfXIAh/2YIRUURt9pa2W086YgZgGjQ0UDC6B5hGBr2VyBRpgQElpJC4tB97UIbsRCT6dXE8OztNhL92Mbh55P4usKq/3sGeEci++ihi5WrDqQl+QhYADyoCa5zLPj0+YuApyS9faj6v+a64G5YcKbHVXR2+4hOuhNw7hzmE4BBmCDu0eMbOKlY6Oto525w2ztLxMXzgSM3sGEOU=----ATTACHMENT:----MjYxOTA3Mzc5ODMyNzY2MCAxOTc5NDkzMjUwNzk3MDAwIDM1MzE0Mjc4MDA2MDE2ODU=