backend
/
fcm
9
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add param ctx.

This commit is contained in:
Владислав Весельский 2025-01-25 10:52:58 +03:00
parent f17a4bdc82
commit 7033f4b75f
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
fcm.go
View File

@ -327,13 +327,18 @@ func makeSendResponseFromPart(part *multipart.Part) (SendResponse, error) {
func (c *Client) SendEach(ctx context.Context, messages []Message) (MessageMultiSendResponse, error) { func (c *Client) SendEach(ctx context.Context, messages []Message) (MessageMultiSendResponse, error) {
_, span := tracer.Start(ctx, "Client.SendEach") ctx, span := tracer.Start(ctx, "Client.SendEach")
defer span.End() defer span.End()
return c.doSendEachInBatch(messages, false) return c.doSendEachInBatch(ctx, messages, false)
} }
func (c *Client) doSendEachInBatch(messages []Message, validateOnly bool) (MessageMultiSendResponse, error) { func (c *Client) doSendEachInBatch(
ctx context.Context,
messages []Message,
validateOnly bool,
) (MessageMultiSendResponse, error) {
messageCount := len(messages) messageCount := len(messages)
if messageCount == 0 { if messageCount == 0 {
return MessageMultiSendResponse{}, nil return MessageMultiSendResponse{}, nil