Killed all outstanding mutants.

Author: Bilge

test/Integration/PorterAsyncTest.php

@@ -8,9 +8,11 @@
 use Amp\Producer;
 use Amp\Promise;
 use ScriptFUSION\Async\Throttle\DualThrottle;
+use ScriptFUSION\Porter\Collection\AsyncPorterRecords;
 use ScriptFUSION\Porter\Collection\AsyncRecordCollection;
 use ScriptFUSION\Porter\Collection\CountableAsyncPorterRecords;
 use ScriptFUSION\Porter\Collection\CountableAsyncProviderRecords;
+use ScriptFUSION\Porter\Collection\PorterRecords;
 use ScriptFUSION\Porter\ForeignResourceException;
 use ScriptFUSION\Porter\ImportException;
 use ScriptFUSION\Porter\IncompatibleProviderException;
@@ -46,6 +48,8 @@ public function testImportAsync(): \Generator
     {
         $records = $this->porter->importAsync($this->specification);
 
+        self::assertInstanceOf(AsyncPorterRecords::class, $records);
+        self::assertNotSame($this->specification, $records->getSpecification(), 'Specification was not cloned.');
         self::assertTrue(yield $records->advance());
         self::assertSame(['foo'], $records->getCurrent());
     }

test/Integration/PorterSyncTest.php

@@ -195,6 +195,20 @@ public function testImportSingle(): void
         $this->porter->import($this->singleSpecification);
     }
 
+    /**
+     * Tests that when a resource returns ProviderRecords, Porter does not wrap the collection again.
+     */
+    public function testProviderRecordsNotDoubleWrapped(): void
+    {
+        $this->resource->shouldReceive('fetch')
+            ->andReturn($records = new ProviderRecords(new \ArrayIterator([]), $this->resource));
+
+        $imported = $this->porter->import($this->specification);
+
+        self::assertInstanceOf(PorterRecords::class, $imported);
+        self::assertSame($records, $imported->getPreviousCollection());
+    }
+
     #endregion
 
     #region Import one

test/Unit/Provider/Resource/IncompatibleResourceExceptionTest.php

@@ -0,0 +1,22 @@
+<?php
+declare(strict_types=1);
+
+namespace ScriptFUSIONTest\Unit\Provider\Resource;
+
+use ScriptFUSION\Porter\IncompatibleResourceException;
+use PHPUnit\Framework\TestCase;
+use ScriptFUSION\Porter\Provider\Resource\SingleRecordResource;
+
+/**
+ * @see IncompatibleResourceException
+ */
+final class IncompatibleResourceExceptionTest extends TestCase
+{
+    public function testCreateMustImplementInterface(): void
+    {
+        self::assertMatchesRegularExpression(
+            sprintf('[.%s\\.]', addslashes(SingleRecordResource::class)),
+            IncompatibleResourceException::createMustImplementInterface()->getMessage()
+        );
+    }
+}