Skip to content

Commit 3b3ce06

Browse files
committed
Use StreamStore and message loader, fix cs
1 parent 2153d2d commit 3b3ce06

2 files changed

Lines changed: 2 additions & 3 deletions

File tree

tests/Integration/BasicImplementation/BasicIntegrationTest.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -329,7 +329,7 @@ public function testCommandBus(): void
329329

330330
public function testQueryBus(): void
331331
{
332-
$store = new DoctrineDbalStore(
332+
$store = new StreamDoctrineDbalStore(
333333
$this->connection,
334334
DefaultEventSerializer::createFromPaths([__DIR__ . '/Events']),
335335
DefaultHeadersSerializer::createFromPaths([
@@ -350,7 +350,7 @@ public function testQueryBus(): void
350350
$profileProjection = new ProfileProjector($this->connection);
351351

352352
$engine = new DefaultSubscriptionEngine(
353-
$store,
353+
new StoreMessageLoader($store),
354354
new InMemorySubscriptionStore(),
355355
new MetadataSubscriberAccessorRepository([
356356
$profileProjection,

tests/Integration/BasicImplementation/Projection/ProfileProjector.php

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313
use Patchlevel\EventSourcing\Attribute\Teardown;
1414
use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\Events\NameChanged;
1515
use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\Events\ProfileCreated;
16-
use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\ProfileId;
1716
use Patchlevel\EventSourcing\Tests\Integration\BasicImplementation\Query\QueryProfileName;
1817

1918
#[Projector('profile-1')]

0 commit comments

Comments
 (0)