diff --git a/src/Porter/Connector/NullConnector.php b/src/Porter/Connector/NullConnector.php new file mode 100644 index 0000000..78626c0 --- /dev/null +++ b/src/Porter/Connector/NullConnector.php @@ -0,0 +1,10 @@ +finalize()->getProviderData(); - if (!$documents = $this->fetch($providerData)) { - return new CountableProviderRecords(new \EmptyIterator, 0, $providerData); - } - - if (!$documents instanceof ProviderRecords) { - // Compose documents iterator. + if (!($documents = $this->fetch($providerData)) instanceof ProviderRecords) { + // Compose records iterator. $documents = new ProviderRecords($documents, $providerData); } diff --git a/src/Porter/Provider/StaticData.php b/src/Porter/Provider/StaticData.php new file mode 100644 index 0000000..0f13766 --- /dev/null +++ b/src/Porter/Provider/StaticData.php @@ -0,0 +1,24 @@ +data = $data; + } + + public function getProviderName() + { + return StaticDataProvider::class; + } + + public function fetch(Connector $connector) + { + return $this->data; + } +} diff --git a/src/Porter/Provider/StaticDataProvider.php b/src/Porter/Provider/StaticDataProvider.php new file mode 100644 index 0000000..35e188e --- /dev/null +++ b/src/Porter/Provider/StaticDataProvider.php @@ -0,0 +1,12 @@ +addProvider(new StaticDataProvider); + $records = $porter->import(new ImportSpecification(new StaticData(new \ArrayIterator(['foo'])))); + + $this->assertSame('foo', $records->current()); + } +}