package c.a.q.e.b;

import c.a.h;
import c.a.j;
import c.a.l;

/* JADX INFO: compiled from: SingleMap.java */
/* JADX INFO: loaded from: classes.dex */
public final class d<T, R> extends h<R> {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    final l<? extends T> f1792a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    final c.a.p.f<? super T, ? extends R> f1793b;

    /* JADX INFO: compiled from: SingleMap.java */
    static final class a<T, R> implements j<T> {

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        final j<? super R> f1794c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        final c.a.p.f<? super T, ? extends R> f1795d;

        a(j<? super R> jVar, c.a.p.f<? super T, ? extends R> fVar) {
            this.f1794c = jVar;
            this.f1795d = fVar;
        }

        @Override // c.a.j, c.a.a, c.a.c
        public void a(c.a.n.b bVar) {
            this.f1794c.a(bVar);
        }

        @Override // c.a.j, c.a.a, c.a.c
        public void b(Throwable th) {
            this.f1794c.b(th);
        }

        @Override // c.a.j
        public void d(T t) {
            try {
                this.f1794c.d(c.a.q.b.b.c(this.f1795d.apply(t), "The mapper function returned a null value."));
            } catch (Throwable th) {
                c.a.o.b.b(th);
                b(th);
            }
        }
    }

    public d(l<? extends T> lVar, c.a.p.f<? super T, ? extends R> fVar) {
        this.f1792a = lVar;
        this.f1793b = fVar;
    }

    @Override // c.a.h
    protected void k(j<? super R> jVar) {
        this.f1792a.a(new a(jVar, this.f1793b));
    }
}