expectException(BufferEmptyError::class); $buffer->read(); } /** * uuid: 2e6db04a-58a1-425d-ade8-ac30b5f318f3 */ public function testCanReadAnItemJustWritten(): void { $buffer = new CircularBuffer(1); $buffer->write('1'); $this->assertSame('1', $buffer->read()); } /** * uuid: 90741fe8-a448-45ce-be2b-de009a24c144 */ public function testEachItemMayOnlyBeReadOnce(): void { $buffer = new CircularBuffer(1); $buffer->write('1'); $this->assertSame('1', $buffer->read()); $this->expectException(BufferEmptyError::class); $buffer->read(); } /** * uuid: be0e62d5-da9c-47a8-b037-5db21827baa7 */ public function testItemsAreReadInTheOrderTheyAreWritten(): void { $buffer = new CircularBuffer(2); $buffer->write('1'); $buffer->write('2'); $this->assertSame('1', $buffer->read()); $this->assertSame('2', $buffer->read()); } /** * uuid: 2af22046-3e44-4235-bfe6-05ba60439d38 */ public function testFullBufferCantBeWrittenTo(): void { $buffer = new CircularBuffer(1); $buffer->write('1'); $this->expectException(BufferFullError::class); $buffer->write('2'); } /** * uuid: 547d192c-bbf0-4369-b8fa-fc37e71f2393 */ public function testAReadFreesUpCapacityForAnotherWrite(): void { $buffer = new CircularBuffer(1); $buffer->write('1'); $this->assertSame('1', $buffer->read()); $buffer->write('2'); $this->assertSame('2', $buffer->read()); } /** * uuid: 04a56659-3a81-4113-816b-6ecb659b4471 */ public function testReadPositionIsMaintainedEvenAcrossMultipleWrites(): void { $buffer = new CircularBuffer(3); $buffer->write('1'); $buffer->write('2'); $this->assertSame('1', $buffer->read()); $buffer->write('3'); $this->assertSame('2', $buffer->read()); $this->assertSame('3', $buffer->read()); } /** * uuid: 60c3a19a-81a7-43d7-bb0a-f07242b1111f */ public function testItemsClearedOutOfBufferCantBeRead(): void { $buffer = new CircularBuffer(1); $buffer->write('1'); $buffer->clear(); $this->expectException(BufferEmptyError::class); $buffer->read(); } /** * uuid: 45f3ae89-3470-49f3-b50e-362e4b330a59 */ public function testClearFreesUpCapacityForAnotherWrite(): void { $buffer = new CircularBuffer(1); $buffer->write('1'); $buffer->clear(); $buffer->write('2'); $this->assertSame('2', $buffer->read()); } /** * uuid: e1ac5170-a026-4725-bfbe-0cf332eddecd */ public function testClearDoesNothingOnEmptyBuffer(): void { $buffer = new CircularBuffer(1); $buffer->clear(); $buffer->write('1'); $this->assertSame('1', $buffer->read()); } /** * uuid: 9c2d4f26-3ec7-453f-a895-7e7ff8ae7b5b */ public function testForceWriteActsLikeWriteOnNonFullBuffer(): void { $buffer = new CircularBuffer(2); $buffer->write('1'); $buffer->forceWrite('2'); $this->assertSame('1', $buffer->read()); $this->assertSame('2', $buffer->read()); } /** * uuid: 880f916b-5039-475c-bd5c-83463c36a147 */ public function testForceWriteReplacesTheOldestItemOnFullBuffer(): void { $buffer = new CircularBuffer(2); $buffer->write('1'); $buffer->write('2'); $buffer->forceWrite('3'); $this->assertSame('2', $buffer->read()); $this->assertSame('3', $buffer->read()); } /** * uuid: bfecab5b-aca1-4fab-a2b0-cd4af2b053c3 */ public function testForceWriteReplacesTheOldestItemRemainingInBufferFollowingARead(): void { $buffer = new CircularBuffer(3); $buffer->write('1'); $buffer->write('2'); $buffer->write('3'); $this->assertSame('1', $buffer->read()); $buffer->write('4'); $buffer->forceWrite('5'); $this->assertSame('3', $buffer->read()); $this->assertSame('4', $buffer->read()); $this->assertSame('5', $buffer->read()); } /** * uuid: 9cebe63a-c405-437b-8b62-e3fdc1ecec5a */ public function testInitialClearDoesNotAffectWrappingAround(): void { $buffer = new CircularBuffer(2); $buffer->clear(); $buffer->write('1'); $buffer->write('2'); $buffer->forceWrite('3'); $buffer->forceWrite('4'); $this->assertSame('3', $buffer->read()); $this->assertSame('4', $buffer->read()); $this->expectException(BufferEmptyError::class); $buffer->read(); } }