diff --git a/src/NATS.Client.JetStream/Models/StreamSource.cs b/src/NATS.Client.JetStream/Models/StreamSource.cs index 5c84a38da..5c19e7f4f 100644 --- a/src/NATS.Client.JetStream/Models/StreamSource.cs +++ b/src/NATS.Client.JetStream/Models/StreamSource.cs @@ -39,11 +39,11 @@ public record StreamSource public string FilterSubject { get; set; } = default!; /// - /// Map matching subjects according to this transform destination + /// Subject transforms to apply to matching messages /// - [System.Text.Json.Serialization.JsonPropertyName("subject_transform_dest")] + [System.Text.Json.Serialization.JsonPropertyName("subject_transforms")] [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)] - public string SubjectTransformDest { get; set; } = default!; + public System.Collections.Generic.ICollection SubjectTransforms { get; set; } = default!; [System.Text.Json.Serialization.JsonPropertyName("external")] [System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)]