// Path: rxgroups/src/main/java/com/airbnb/rxgroups/processor/ProcessorHelper.java
// public class ProcessorHelper {
// 
//   public static final String GENERATED_CLASS_NAME_SUFFIX = "_ObservableResubscriber";
// 
// }


import com.airbnb.rxgroups.processor.ProcessorHelper;
import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
import java.util.LinkedHashMap;
import java.util.Map;
import javax.annotation.Nullable;
    } catch (IllegalAccessException e) {
      throw new RuntimeException("Unable to invoke " + constructor, e);
    } catch (InstantiationException e) {
      throw new RuntimeException("Unable to invoke " + constructor, e);
    } catch (InvocationTargetException e) {
      Throwable cause = e.getCause();
      if (cause instanceof RuntimeException) {
        throw (RuntimeException) cause;
      }
      if (cause instanceof Error) {
        throw (Error) cause;
      }
      throw new RuntimeException("Unable to create resubscribeAll instance.", cause);
    }
  }

  @Nullable
  private static Constructor<?> findConstructorForClass(Class<?> cls) {
    Constructor<?> bindingCtor = BINDINGS.get(cls);
    if (bindingCtor != null || BINDINGS.containsKey(cls)) {
      return bindingCtor;
    }

    String clsName = cls.getName();
    if (clsName.startsWith("android.") || clsName.startsWith("java.")) {
      BINDINGS.put(cls, bindingCtor);
      return null;
    }
    try {
      Class<?> bindingClass = Class.forName(clsName
// Path: rxgroups/src/main/java/com/airbnb/rxgroups/processor/ProcessorHelper.java
// public class ProcessorHelper {
// 
//   public static final String GENERATED_CLASS_NAME_SUFFIX = "_ObservableResubscriber";
// 
// }


// Path: rxgroups/src/main/java/com/airbnb/rxgroups/ResubscribeHelper.java
import com.airbnb.rxgroups.processor.ProcessorHelper;
import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
import java.util.LinkedHashMap;
import java.util.Map;
import javax.annotation.Nullable;

    } catch (IllegalAccessException e) {
      throw new RuntimeException("Unable to invoke " + constructor, e);
    } catch (InstantiationException e) {
      throw new RuntimeException("Unable to invoke " + constructor, e);
    } catch (InvocationTargetException e) {
      Throwable cause = e.getCause();
      if (cause instanceof RuntimeException) {
        throw (RuntimeException) cause;
      }
      if (cause instanceof Error) {
        throw (Error) cause;
      }
      throw new RuntimeException("Unable to create resubscribeAll instance.", cause);
    }
  }

  @Nullable
  private static Constructor<?> findConstructorForClass(Class<?> cls) {
    Constructor<?> bindingCtor = BINDINGS.get(cls);
    if (bindingCtor != null || BINDINGS.containsKey(cls)) {
      return bindingCtor;
    }

    String clsName = cls.getName();
    if (clsName.startsWith("android.") || clsName.startsWith("java.")) {
      BINDINGS.put(cls, bindingCtor);
      return null;
    }
    try {
      Class<?> bindingClass = Class.forName(clsName
          + ProcessorHelper.GENERATED_CLASS_NAME_SUFFIX);