package com.l7tech.common.http.prov.apache.components;

import java.io.IOException;
import java.io.InputStream;
import org.apache.commons.io.input.ObservableInputStream;
import org.apache.hc.client5.http.classic.methods.HttpUriRequestBase;
import org.apache.hc.core5.http.HttpEntity;
import org.apache.hc.core5.http.io.entity.HttpEntityWrapper;

class n extends HttpEntityWrapper {
   HttpUriRequestBase a;

   public n(HttpEntity var1, HttpUriRequestBase var2) {
      super(var1);
      this.a = var2;
   }

   public InputStream getContent() throws IOException {
      ObservableInputStream var1 = new ObservableInputStream(super.getContent());
      var1.add(new k(this));
      return var1;
   }
}