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 */
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;
    }

    public final Integer call(List<Message> list, StoreMessageAck.Ack ack) {
        int i = 0;
        if (!list.isEmpty()) {
            if ((ack != null ? Long.valueOf(ack.getMessageId()) : null) != null) {
                m.checkNotNullExpressionValue(list, "messages");
                for (Message message : s.asReversed(list)) {
                    if (message.getId() == ack.getMessageId()) {
                        break;
                    } else if (StoreReadStates.access$wasMessageSentAfterTimestamp(this.this$0, this.$since, Long.valueOf(message.getId()))) {
                        i++;
                    }
                }
            }
        }
        return Integer.valueOf(i);
    }

    /* Return type fixed from 'java.lang.Object' to match base method */
    /* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object, java.lang.Object] */
    @Override // rx.functions.Func2
    public /* bridge */ /* synthetic */ Integer call(List<? extends Message> list, StoreMessageAck.Ack ack) {
        return call((List<Message>) list, ack);
    }
}