package com.trello.rxlifecycle3.android;

import android.view.View;
import f.a.j;
import f.a.k;
import f.a.s.a;
import f.a.w.a.b;
import f.a.w.e.d.c;
import java.util.Objects;

/* JADX INFO: loaded from: classes.dex */
public final class ViewDetachesOnSubscribe implements k<Object> {
    public static final Object SIGNAL = new Object();
    public final View view;

    public class EmitterListener extends a implements View.OnAttachStateChangeListener {
        public final j<Object> emitter;

        public EmitterListener(j<Object> jVar) {
            this.emitter = jVar;
        }

        @Override // f.a.s.a
        public void onDispose() {
            ViewDetachesOnSubscribe.this.view.removeOnAttachStateChangeListener(this);
        }

        @Override // android.view.View.OnAttachStateChangeListener
        public void onViewAttachedToWindow(View view) {
        }

        @Override // android.view.View.OnAttachStateChangeListener
        public void onViewDetachedFromWindow(View view) {
            ((c.a) this.emitter).d(ViewDetachesOnSubscribe.SIGNAL);
        }
    }

    public ViewDetachesOnSubscribe(View view) {
        this.view = view;
    }

    @Override // f.a.k
    public void subscribe(j<Object> jVar) throws Exception {
        a.verifyMainThread();
        EmitterListener emitterListener = new EmitterListener(jVar);
        c.a aVar = (c.a) jVar;
        Objects.requireNonNull(aVar);
        b.set(aVar, emitterListener);
        this.view.addOnAttachStateChangeListener(emitterListener);
    }
}