Implement Storage with Transaction generic

vudaltsov · vudaltsov · commit 4d6174cbdb09 · 2025-07-18T04:36:11.000+03:00
diff --git a/composer.lock b/composer.lock
diff --git a/src/PostgresStorage.php b/src/PostgresStorage.php
@@ -5,6 +5,7 @@
 namespace Thesis\MessageBus\Persistence\Postgres;
 
 use Amp\Postgres\PostgresLink;
+use Amp\Postgres\PostgresTransaction as AmphpPostgresTransaction;
 use Thesis\Message\Command;
 use Thesis\Message\Event;
 use Thesis\MessageBus\Envelope;
@@ -14,6 +15,7 @@
 
 /**
  * @api
+ * @implements Storage<AmphpPostgresTransaction>
  */
 final readonly class PostgresStorage implements Storage
 {
diff --git a/src/PostgresTransaction.php b/src/PostgresTransaction.php
@@ -15,6 +15,7 @@
 /**
  * @internal
  * @psalm-internal Thesis\MessageBus\Persistence\Postgres
+ * @implements Transaction<AmphpPostgresTransaction>
  */
 final readonly class PostgresTransaction implements Transaction
 {

Original file line number	Diff line number	Diff line change
`@@ -15,6 +15,7 @@`
`15`	`15`	`/**`
`16`	`16`	`* @internal`
`17`	`17`	`* @psalm-internal Thesis\MessageBus\Persistence\Postgres`
	`18`	`+ * @implements Transaction<AmphpPostgresTransaction>`
`18`	`19`	`*/`
`19`	`20`	`final readonly class PostgresTransaction implements Transaction`
`20`	`21`	`{`