File tree Expand file tree Collapse file tree 3 files changed +5
-7
lines changed
src/Ydb.Sdk/src/Services/Topic Expand file tree Collapse file tree 3 files changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -16,7 +16,7 @@ internal class Producer<TValue> : IProducer<TValue>
1616 private readonly long _partitionId ;
1717 private readonly string _sessionId ;
1818 private readonly ISerializer < TValue > _serializer ;
19-
19+
2020 private long _seqNum ;
2121
2222 private readonly ConcurrentQueue < StreamWriteMessage . Types . FromClient > _inFlightMessages ;
@@ -25,7 +25,7 @@ internal class Producer<TValue> : IProducer<TValue>
2525 internal Producer (
2626 ProducerConfig producerConfig ,
2727 StreamWriteMessage . Types . InitResponse initResponse ,
28- ProducerStream stream ,
28+ ProducerStream stream ,
2929 ISerializer < TValue > serializer )
3030 {
3131 _driver = producerConfig . Driver ;
@@ -73,11 +73,11 @@ public SendResult(State status)
7373public enum State
7474{
7575 Written ,
76- AlreadyWritten ,
76+ AlreadyWritten
7777}
7878
7979internal enum ProducerState
8080{
81- Ready ,
81+ Ready
8282 // Broken
8383}
Original file line number Diff line number Diff line change 1-
21namespace Ydb . Sdk . Services . Topic ;
32
43public class ProducerConfig
Original file line number Diff line number Diff line change 11using System . Text ;
2- using Grpc . Core ;
32
43namespace Ydb . Sdk . Services . Topic ;
54
@@ -35,7 +34,7 @@ public static class Serializers
3534 { typeof ( string ) , Utf8 } ,
3635 { typeof ( byte [ ] ) , ByteArray }
3736 } ;
38-
37+
3938 private class Utf8Serializer : ISerializer < string >
4039 {
4140 public byte [ ] Serialize ( string data )
You can’t perform that action at this time.
0 commit comments