File tree Expand file tree Collapse file tree 4 files changed +5
-6
lines changed
src/Services/Topic/Reader Expand file tree Collapse file tree 4 files changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -53,7 +53,7 @@ internal bool TryDequeueMessage([MaybeNullWhen(false)] out Message<TValue> messa
5353 {
5454 throw new ReaderException ( "Error when deserializing message data" , e ) ;
5555 }
56-
56+
5757 var nextCommitedOffset = messageData . Offset + 1 ;
5858
5959 message = new Message < TValue > (
Original file line number Diff line number Diff line change @@ -89,7 +89,7 @@ internal void Stop(long commitedOffset)
8989 }
9090 else
9191 {
92- Utils . SetPartitionClosedException ( commitSending , PartitionSessionId ) ;
92+ Utils . SetPartitionClosedException ( commitSending , PartitionSessionId ) ;
9393 }
9494 }
9595 }
Original file line number Diff line number Diff line change @@ -203,7 +203,7 @@ public void Dispose()
203203 try
204204 {
205205 _receivedMessagesChannel . Writer . TryComplete ( ) ;
206-
206+
207207 _disposeCts . Cancel ( ) ;
208208 }
209209 finally
@@ -421,7 +421,7 @@ private async Task StopPartitionSessionRequest(
421421 if ( stopPartitionSessionRequest . Graceful )
422422 {
423423 partitionSession . Stop ( stopPartitionSessionRequest . CommittedOffset ) ;
424-
424+
425425 await _channelFromClientMessageSending . Writer . WriteAsync ( new MessageFromClient
426426 {
427427 StopPartitionSessionResponse = new StreamReadMessage . Types . StopPartitionSessionResponse
@@ -431,7 +431,7 @@ await _channelFromClientMessageSending.Writer.WriteAsync(new MessageFromClient
431431 else
432432 {
433433 // Maybe a race condition with the server dropping all waiters before they can commit.
434- partitionSession . Stop ( - 1 ) ;
434+ partitionSession . Stop ( - 1 ) ;
435435 }
436436 }
437437 else
Original file line number Diff line number Diff line change 1- using System . ComponentModel ;
21using System . Text ;
32using Google . Protobuf ;
43using Google . Protobuf . WellKnownTypes ;
You can’t perform that action at this time.
0 commit comments