Skip to content

Commit 433a57b

Browse files
committed
fixes
1 parent 1390a22 commit 433a57b

File tree

1 file changed

+3
-11
lines changed

1 file changed

+3
-11
lines changed

packages/PdoEventSourcing/src/Config/ProophProjectingModule.php

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -238,9 +238,7 @@ public function getModuleExtensions(ServiceConfiguration $serviceConfiguration,
238238
$eventStreamingChannelAdapters = ExtensionObjectResolver::resolve(EventStreamingChannelAdapter::class, $serviceExtensions);
239239

240240
if (($this->projectionNames || $eventStreamingChannelAdapters) && ! $eventSourcingConfiguration->isInMemory()) {
241-
$projectionNames = array_unique([...$this->projectionNames, ...array_map(fn (EventStreamingChannelAdapter $adapter) => $adapter->getProjectionName(), $eventStreamingChannelAdapters)]);
242-
243-
$extensions[] = new ProjectionStateStorageReference(DbalProjectionStateStorage::class, $projectionNames);
241+
$extensions[] = new ProjectionStateStorageReference(DbalProjectionStateStorage::class);
244242
}
245243

246244
if ($this->partitionedProjectionNames !== [] && ! $eventSourcingConfiguration->isInMemory()) {
@@ -254,16 +252,10 @@ public function getModuleExtensions(ServiceConfiguration $serviceConfiguration,
254252
]);
255253

256254
if ($globalStreamProjectionNames !== []) {
257-
$extensions[] = new StreamSourceReference(
258-
EventStoreGlobalStreamSource::class,
259-
$globalStreamProjectionNames
260-
);
255+
$extensions[] = new StreamSourceReference(EventStoreGlobalStreamSource::class);
261256
}
262257
if ($this->partitionedProjectionNames !== []) {
263-
$extensions[] = new StreamSourceReference(
264-
EventStoreAggregateStreamSource::class,
265-
$this->partitionedProjectionNames
266-
);
258+
$extensions[] = new StreamSourceReference(EventStoreAggregateStreamSource::class);
267259
}
268260
}
269261

0 commit comments

Comments
 (0)