anchor.diff:      return completer.future;
     }
   
  -  void closeWithError(TespResponseError error) {
  -    _tespResponseCompleterQueue.forEach((e) => e.completer.complete(error));
  -    close(force: true);
  -  }
  -
     Future<void> close({bool force = false}) async {
       try {
         if (!force) {
  
positive.code:       }
      }
  
      _tespSocket.listen(onResponse, onError: (e) {
        if (e is TimeoutException) {
          closeWithError(TespResponseError(
              TespResponseError.tespClientErrorChunkTimeout, '$e'));
  
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;
  