Skip to content

Commit d75f974

Browse files
fix linter
1 parent 81e7977 commit d75f974

File tree

2 files changed

+15
-9
lines changed

2 files changed

+15
-9
lines changed

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,9 +51,14 @@ public Task<SendResult> SendAsync(Message<TValue> message)
5151

5252
public class Message<TValue>
5353
{
54+
public Message(TValue data)
55+
{
56+
Data = data;
57+
}
58+
5459
public DateTime Timestamp { get; set; }
5560

56-
public TValue Data { get; set; }
61+
public TValue Data { get; }
5762

5863
public List<Metadata> Metadata { get; } = new();
5964
}

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

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -47,13 +47,14 @@ public async Task<IProducer<TValue>> Build()
4747
throw new YdbProducerException($"Topic is not supported codec: {_config.Codec}");
4848
}
4949

50-
return new Producer<TValue>(
51-
_config, initResponse, stream,
52-
Serializer ?? (ISerializer<TValue>)(
53-
Serializers.DefaultSerializers.TryGetValue(typeof(TValue), out var serializer)
54-
? serializer
55-
: throw new YdbProducerException("The serializer is not set")
56-
)
57-
);
50+
throw new NotImplementedException();
51+
// return new Producer<TValue>(
52+
// _config, initResponse, stream,
53+
// Serializer ?? (ISerializer<TValue>)(
54+
// Serializers.DefaultSerializers.TryGetValue(typeof(TValue), out var serializer)
55+
// ? serializer
56+
// : throw new YdbProducerException("The serializer is not set")
57+
// )
58+
// );
5859
}
5960
}

0 commit comments

Comments
 (0)