anchor.diff:                () => closeWithError(TespResponseError(
                     TespResponseError.tespClientErrorResponseTimeout)));
           }
  -        subscription.resume();
  +        sendingSubscription.resume();
         });
       });
   
  
positive.code:     _sendingBuffer = StreamController();
      _tespResponseCompleterQueue = Queue();
      var stopwatch = Stopwatch();
      StreamSubscription subscription;
  
      subscription = _sendingBuffer.stream.listen((tespRequestWrapper) {
        subscription.pause();
        stopwatch.start();
        _tespSocket.add(tespRequestWrapper.tespRequest);
        _socket.flush().then((_) {
  
negative.code: class TespClient {
    final serverAddress;
    final int port;
    /// Maximum allowed time between two consecutive chunks belonging to the same response
    final Duration chunkTimeoutMillis;
    /// Maximum allowed time between
    /// (1) sending of one request is finished or previous request get responded, whichever happens later,
    /// and
    /// (2) a response is received
    final Duration responseTimeoutMillis;
    /// Timeout for connection to the server
    final Duration connectionTimeoutMillis;
  
    Socket _socket;
  