File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 44using Ydb . Sdk . Services . Topic . Writer ;
55using Ydb . Sdk . Tests . Fixture ;
66using Ydb . Topic ;
7+ using Ydb . Topic . V1 ;
78using Consumer = Ydb . Sdk . Services . Topic . Consumer ;
89
910namespace Ydb . Sdk . Tests . Topic ;
@@ -75,8 +76,7 @@ public async Task WriteAsync_When1000Messages_ReturnWriteResultIsPersisted()
7576
7677 await Task . WhenAll ( tasks ) ;
7778
78- var initStream =
79- _driver . BidirectionalStreamCall ( Ydb . Topic . V1 . TopicService . StreamReadMethod , new GrpcRequestSettings ( ) ) ;
79+ var initStream = _driver . BidirectionalStreamCall ( TopicService . StreamReadMethod , new GrpcRequestSettings ( ) ) ;
8080 await initStream . Write ( new StreamReadMessage . Types . FromClient
8181 {
8282 InitRequest = new StreamReadMessage . Types . InitRequest
@@ -106,7 +106,7 @@ await initStream.Write(new StreamReadMessage.Types.FromClient
106106 StartPartitionSessionResponse = new StreamReadMessage . Types . StartPartitionSessionResponse
107107 {
108108 CommitOffset = startRequest . CommittedOffset ,
109- PartitionSessionId = startRequest . PartitionSession . PartitionSessionId ,
109+ PartitionSessionId = startRequest . PartitionSession . PartitionSessionId
110110 }
111111 } ) ;
112112 var receivedMessageCount = 0 ;
You can’t perform that action at this time.
0 commit comments