package c.a.q.h;

import c.a.q.g.g;

/* JADX INFO: compiled from: BlockingHelper.java */
/* JADX INFO: loaded from: classes.dex */
public final class a {
    public static void a() {
        if (c.a.r.a.j()) {
            if ((Thread.currentThread() instanceof g) || c.a.r.a.m()) {
                throw new IllegalStateException("Attempt to block on a Scheduler " + Thread.currentThread().getName() + " that doesn't support blocking operators as they may lead to deadlock");
            }
        }
    }
}