File tree 1 file changed +2
-5
lines changed
1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -109,12 +109,9 @@ public async Task<List<T>> SendAsync<T>(IKafkaRequest<T> request)
109
109
110
110
try
111
111
{
112
- var sendTask = SendAsync ( request . Encode ( ) ) ;
113
- //synchronously add the response message as soon as the send succeeds. If the KafkaTcpSocket is trying establish a connection
114
- //the SendAsync call will block until its establish. If we added response to queue before, it would timeout seperately from the send.
115
- sendTask . ContinueWith ( t => AddAsyncRequestItemToResponseQueue ( asyncRequest ) , TaskContinuationOptions . ExecuteSynchronously ) ;
112
+ AddAsyncRequestItemToResponseQueue ( asyncRequest ) ;
116
113
117
- await sendTask . ConfigureAwait ( false ) ;
114
+ await SendAsync ( request . Encode ( ) ) . ConfigureAwait ( false ) ;
118
115
}
119
116
catch ( OperationCanceledException ex )
120
117
{
You can’t perform that action at this time.
0 commit comments