diff --git a/src/Postgres/src/Eventuous.Postgresql/Subscriptions/PostgresStreamSubscription.cs b/src/Postgres/src/Eventuous.Postgresql/Subscriptions/PostgresStreamSubscription.cs
index 45f917a1..a1f4199d 100644
--- a/src/Postgres/src/Eventuous.Postgresql/Subscriptions/PostgresStreamSubscription.cs
+++ b/src/Postgres/src/Eventuous.Postgresql/Subscriptions/PostgresStreamSubscription.cs
@@ -69,4 +69,9 @@ protected override EventPosition GetPositionFromContext(IMessageConsumeContext c
         => EventPosition.FromContext(context);
 }
 
-public record PostgresStreamSubscriptionOptions(StreamName Stream) : PostgresSubscriptionBaseOptions;
+public record PostgresStreamSubscriptionOptions : PostgresSubscriptionBaseOptions {
+    /// <summary>
+    /// Stream name to subscribe for
+    /// </summary>
+    public StreamName Stream { get; set; }
+}
diff --git a/src/Postgres/test/Eventuous.Tests.Postgres/Fixtures/SubscriptionFixture.cs b/src/Postgres/test/Eventuous.Tests.Postgres/Fixtures/SubscriptionFixture.cs
index b5d7830d..37aa4dca 100644
--- a/src/Postgres/test/Eventuous.Tests.Postgres/Fixtures/SubscriptionFixture.cs
+++ b/src/Postgres/test/Eventuous.Tests.Postgres/Fixtures/SubscriptionFixture.cs
@@ -49,7 +49,8 @@ protected SubscriptionFixture(
             !subscribeToAll
                 ? new PostgresStreamSubscription(
                     IntegrationFixture.DataSource,
-                    new PostgresStreamSubscriptionOptions(Stream) {
+                    new PostgresStreamSubscriptionOptions {
+                        Stream = Stream,
                         SubscriptionId = SubscriptionId,
                         Schema         = IntegrationFixture.SchemaName
                     },