package com.l7tech.common.io;

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

public class EofCallbackInputStream extends FilterInputStream {
   private Runnable a;

   // $VF: Handled exception range with multiple entry points by splitting it
   // $VF: Duplicated exception handlers to handle obfuscated exceptions
   public EofCallbackInputStream(InputStream var1, Runnable var2) {
      label17: {
         super(var1);
         this.a = null;
         if (var1 != null) {
            try {
               if (var2 != null) {
                  break label17;
               }
            } catch (NullPointerException var4) {
               throw a(var4);
            }
         }

         try {
            throw new NullPointerException();
         } catch (NullPointerException var3) {
            throw a(var3);
         }
      }

      this.a = var2;
   }

   private void a() {
      if (this.a != null) {
         Runnable var1 = this.a;
         this.a = null;
         var1.run();
      }
   }

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

      try {
         if (var2 < 0) {
            this.a();
         }

         return var2;
      } catch (IOException var3) {
         throw a(var3);
      }
   }

   @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();
         }

         return var4;
      } catch (IOException var5) {
         throw a(var5);
      }
   }

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

      try {
         if (var1 < 0) {
            this.a();
         }

         return var1;
      } catch (IOException var2) {
         throw a(var2);
      }
   }

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

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