package com.discord.stores;

import com.discord.utilities.messagesend.MessageQueue;
import com.discord.utilities.messagesend.MessageRequest;
import com.discord.utilities.messagesend.MessageResult;
import d0.z.d.m;
import kotlin.jvm.functions.Function1;
import rx.Emitter;
import rx.functions.Action1;
/* compiled from: StoreMessages.kt */
public final class StoreMessages$sendMessage$5<T> implements Action1<Emitter<MessageResult>> {
    public final /* synthetic */ long $channelId;
    public final /* synthetic */ Function1 $request;
    public final /* synthetic */ StoreMessages this$0;

    public StoreMessages$sendMessage$5(StoreMessages storeMessages, long j, Function1 function1) {
        this.this$0 = storeMessages;
        this.$channelId = j;
        this.$request = function1;
    }

    public final void call(Emitter<MessageResult> emitter) {
        MessageQueue access$getOrCreateMessageQueue = StoreMessages.access$getOrCreateMessageQueue(this.this$0, this.$channelId);
        Function1 function1 = this.$request;
        m.checkNotNullExpressionValue(emitter, "emitter");
        access$getOrCreateMessageQueue.enqueue((MessageRequest) function1.invoke(emitter));
    }
}