package ed;

import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes.dex */
public final class j {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final AtomicBoolean f25835a = new AtomicBoolean(false);

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ tb.d f25836b;

    public j(tb.d dVar) {
        this.f25836b = dVar;
    }

    public final void a(Object obj) {
        if (this.f25835a.get()) {
            return;
        }
        tb.d dVar = this.f25836b;
        if (((AtomicReference) dVar.f33021c).get() != this) {
            return;
        }
        Object obj2 = dVar.f33022d;
        ((l) obj2).f25837a.send(((l) obj2).f25838b, ((l) obj2).f25839c.encodeSuccessEnvelope(obj));
    }
}