package com.l7tech.common.io;

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

public class TeeInputStream extends FilterInputStream {
   private final OutputStream a;

   public TeeInputStream(InputStream var1, OutputStream var2) {
      super(var1);
      this.a = var2;
      this.in.getClass();
      this.a.getClass();
   }

   @Override
   public int read() throws IOException {
      int var1 = super.read();

      try {
         if (var1 < 0) {
            this.a.flush();
            return var1;
         }
      } catch (IOException var2) {
         throw a(var2);
      }

      this.a.write(var1);
      return var1;
   }

   @Override
   public int read(byte[] var1, int var2, int var3) throws IOException {
      int var4 = super.read(var1, var2, var3);

      try {
         if (var4 <= 0) {
            this.a.flush();
            return var4;
         }
      } catch (IOException var5) {
         throw a(var5);
      }

      this.a.write(var1, var2, var4);
      return var4;
   }

   @Override
   public void close() throws IOException {
      try {
         this.a.close();
      } finally {
         super.close();
      }
   }

   private static IOException a(IOException var0) {
      return var0;
   }
}