package com.discord.stores;

import com.discord.api.utcdatetime.UtcDateTime;
import com.discord.models.message.Message;
import com.discord.stores.StoreMessageAck;
import d0.t.s;
import d0.z.d.m;
import java.util.List;
import rx.functions.Func2;
/* compiled from: StoreReadStates.kt */
/* loaded from: classes.dex */
public final class StoreReadStates$observeUnreadCountForChannel$2<T1, T2, R> implements Func2<List<? extends Message>, StoreMessageAck.Ack, Integer> {
    public final /* synthetic */ UtcDateTime $since;
    public final /* synthetic */ StoreReadStates this$0;

    public StoreReadStates$observeUnreadCountForChannel$2(StoreReadStates storeReadStates, UtcDateTime utcDateTime) {
        this.this$0 = storeReadStates;
        this.$since = utcDateTime;
    }

    /* renamed from: call  reason: avoid collision after fix types in other method */
    public final Integer call2(List<Message> list, StoreMessageAck.Ack ack) {
        Long valueOf = ack != null ? Long.valueOf(ack.getMessageId()) : null;
        m.checkNotNullExpressionValue(list, "messages");
        int i = 0;
        if (!list.isEmpty()) {
            for (Message message : s.asReversed(list)) {
                if (valueOf != null && message.getId() == ack.getMessageId()) {
                    break;
                } else if (StoreReadStates.access$wasMessageSentAfterTimestamp(this.this$0, this.$since, Long.valueOf(message.getId()))) {
                    i++;
                }
            }
        }
        return Integer.valueOf(i);
    }

    @Override // rx.functions.Func2
    public /* bridge */ /* synthetic */ Integer call(List<? extends Message> list, StoreMessageAck.Ack ack) {
        return call2((List<Message>) list, ack);
    }
}