package b.f.j.p;

import b.f.j.j.c;
import com.facebook.common.references.CloseableReference;
import com.facebook.imagepipeline.request.ImageRequest;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/* compiled from: DelayProducer */
public class o implements v0<CloseableReference<c>> {
    public final v0<CloseableReference<c>> a;

    /* renamed from: b  reason: collision with root package name */
    public final ScheduledExecutorService f617b;

    /* compiled from: DelayProducer */
    public class a implements Runnable {
        public final /* synthetic */ l j;
        public final /* synthetic */ w0 k;

        public a(l lVar, w0 w0Var) {
            this.j = lVar;
            this.k = w0Var;
        }

        @Override // java.lang.Runnable
        public void run() {
            o.this.a.b(this.j, this.k);
        }
    }

    public o(v0<CloseableReference<c>> v0Var, ScheduledExecutorService scheduledExecutorService) {
        this.a = v0Var;
        this.f617b = scheduledExecutorService;
    }

    @Override // b.f.j.p.v0
    public void b(l<CloseableReference<c>> lVar, w0 w0Var) {
        ImageRequest e = w0Var.e();
        ScheduledExecutorService scheduledExecutorService = this.f617b;
        if (scheduledExecutorService != null) {
            scheduledExecutorService.schedule(new a(lVar, w0Var), (long) e.f2862s, TimeUnit.MILLISECONDS);
        } else {
            this.a.b(lVar, w0Var);
        }
    }
}