package com.mbridge.msdk.dycreator.bus;
/* loaded from: classes5.dex */
class AsyncPoster implements Runnable {

    /* renamed from: a  reason: collision with root package name */
    private final PendingPostQueue f3492a = new PendingPostQueue();
    private final EventBus b;

    /* JADX INFO: Access modifiers changed from: package-private */
    public AsyncPoster(EventBus eventBus) {
        this.b = eventBus;
    }

    public void enqueue(Subscription subscription, Object obj) {
        this.f3492a.a(PendingPost.a(subscription, obj));
        EventBus.f3494a.execute(this);
    }

    @Override // java.lang.Runnable
    public void run() {
        PendingPost a2 = this.f3492a.a();
        if (a2 == null) {
            throw new IllegalStateException("No pending post available");
        }
        this.b.a(a2);
    }
}