Revert marking response timeout after send.

Caused way to many thread contentions. Needs to be rethought.
Jroland · Apr 10, 2015 · c307569 · c307569
1 parent addc9c1
commit c307569
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/kafka-net/KafkaConnection.cs b/src/kafka-net/KafkaConnection.cs
@@ -109,12 +109,9 @@ public async Task<List<T>> SendAsync<T>(IKafkaRequest<T> request)
 
                 try
                 {
-                    var sendTask = SendAsync(request.Encode());
-                    //synchronously add the response message as soon as the send succeeds.  If the KafkaTcpSocket is trying establish a connection
-                    //the SendAsync call will block until its establish.  If we added response to queue before, it would timeout seperately from the send.
-                    sendTask.ContinueWith(t => AddAsyncRequestItemToResponseQueue(asyncRequest), TaskContinuationOptions.ExecuteSynchronously);
+                    AddAsyncRequestItemToResponseQueue(asyncRequest);
 
-                    await sendTask.ConfigureAwait(false);
+                    await SendAsync(request.Encode()).ConfigureAwait(false);
                 }
                 catch (OperationCanceledException ex)
                 {