Skip to content

Instantly share code, notes, and snippets.

@dipeshdulal
Created July 12, 2020 03:50
Show Gist options
  • Save dipeshdulal/961498ac49e9d9d36bf55486f8074aa2 to your computer and use it in GitHub Desktop.
Save dipeshdulal/961498ac49e9d9d36bf55486f8074aa2 to your computer and use it in GitHub Desktop.
Client Send Message Go Routine
func sendMessage(ctx context.Context, client chatpb.ChatServiceClient, message string) {
stream, err := client.SendMessage(ctx)
if err != nil {
log.Printf("Cannot send message: error: %v", err)
}
msg := chatpb.Message{
Channel: &chatpb.Channel{
Name: *channelName,
SendersName: *senderName},
Message: message,
Sender: *senderName,
}
stream.Send(&msg)
ack, err := stream.CloseAndRecv()
fmt.Printf("Message sent: %v \n", ack)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment