Skip to content

Commit d1fd455

Browse files
committed
Fix bug
1 parent aa733d8 commit d1fd455

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

src/SubscriptionRepository.php

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -52,11 +52,13 @@ public function clearConnection(string $connectionId): void
5252
]);
5353

5454
$this->dynamoDb->batchWriteItem([
55-
$this->table => collect($response['Items'])->map(fn($item) => [
56-
'DeleteRequest' => [
57-
'Key' => Arr::only($item, ['connectionId', 'channel']),
58-
],
59-
])->toArray(),
55+
'RequestItems' => [
56+
$this->table => collect($response['Items'])->map(fn($item) => [
57+
'DeleteRequest' => [
58+
'Key' => Arr::only($item, ['connectionId', 'channel']),
59+
],
60+
])->toArray(),
61+
],
6062
]);
6163
}
6264

0 commit comments

Comments
 (0)