src/main/java/com/uber/rss/clients/RecordSocketReadClient.java [65:73]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void close() {
        try {
            dataBlockSocketReadClient.close();
        } catch (Throwable ex) {
            logger.warn(String.format("Failed to close %s", this), ex);
        }

        closeMetrics();
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/clients/ShuffleDataSocketReadClient.java [65:73]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void close() {
    try {
      dataBlockSocketReadClient.close();
    } catch (Throwable ex) {
      logger.warn(String.format("Failed to close %s", this), ex);
    }

    closeMetrics();
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -