fix

Author: KirillKurdyukov

src/Ydb.Sdk/src/Services/Topic/Writer.cs

@@ -18,6 +18,7 @@ namespace Ydb.Sdk.Services.Topic;
 
 internal class Writer<TValue> : IWriter<TValue>
 {
+    private readonly Driver _driver;
     private readonly WriterConfig _config;
     private readonly ILogger<Writer<TValue>> _logger;
     private readonly ISerializer<TValue> _serializer;
@@ -28,18 +29,19 @@ internal class Writer<TValue> : IWriter<TValue>
 
     private volatile WriterSession _session = null!;
 
-    internal Writer(WriterConfig config, ISerializer<TValue> serializer)
+    internal Writer(Driver driver, WriterConfig config, ISerializer<TValue> serializer)
     {
+        _driver = driver;
         _config = config;
         _serializer = serializer;
-        _logger = config.Driver.LoggerFactory.CreateLogger<Writer<TValue>>();
+        _logger = driver.LoggerFactory.CreateLogger<Writer<TValue>>();
     }
 
     internal async Task Initialize()
     {
         _logger.LogInformation("Writer session initialization started. WriterConfig: {WriterConfig}", _config);
 
-        var stream = _config.Driver.BidirectionalStreamCall(
+        var stream = _driver.BidirectionalStreamCall(
             TopicService.StreamWriteMethod,
             GrpcRequestSettings.DefaultInstance
         );

src/Ydb.Sdk/src/Services/Topic/WriterBuilder.cs

@@ -3,9 +3,11 @@ namespace Ydb.Sdk.Services.Topic;
 public class WriterBuilder<TValue>
 {
     private readonly WriterConfig _config;
+    private readonly Driver _driver;
 
-    public WriterBuilder(WriterConfig config)
+    public WriterBuilder(Driver driver, WriterConfig config)
     {
+        _driver = driver;
         _config = config;
     }
 
@@ -14,6 +16,7 @@ public WriterBuilder(WriterConfig config)
     public async Task<IWriter<TValue>> Build()
     {
         var writer = new Writer<TValue>(
+            _driver,
             _config,
             Serializer ?? (ISerializer<TValue>)(
                 Serializers.DefaultSerializers.TryGetValue(typeof(TValue), out var serializer)

src/Ydb.Sdk/src/Services/Topic/WriterConfig.cs

@@ -4,13 +4,11 @@ namespace Ydb.Sdk.Services.Topic;
 
 public class WriterConfig
 {
-    public WriterConfig(Driver driver, string topicPath)
+    public WriterConfig(string topicPath)
     {
-        Driver = driver;
         TopicPath = topicPath;
     }
 
-    public Driver Driver { get; }
     public string TopicPath { get; }
     public string? ProducerId { get; set; }
     public string? MessageGroupId { get; set; }