func()

in gapic/agent_communication_client.go [195:210]

• 16 lines of code
• 2 McCabe index (conditional complexity)

func (c *gRPCClient) StreamAgentMessages(ctx context.Context, opts ...gax.CallOption) (agentcommunicationpb.AgentCommunication_StreamAgentMessagesClient, error) {
	ctx = gax.InsertMetadataIntoOutgoingContext(ctx, c.xGoogHeaders...)
	var resp agentcommunicationpb.AgentCommunication_StreamAgentMessagesClient
	opts = append((*c.CallOptions).StreamAgentMessages[0:len((*c.CallOptions).StreamAgentMessages):len((*c.CallOptions).StreamAgentMessages)], opts...)
	err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error {
		var err error
		c.logger.DebugContext(ctx, "api streaming client request", "serviceName", serviceName, "rpcName", "StreamAgentMessages")
		resp, err = c.client.StreamAgentMessages(ctx, settings.GRPC...)
		c.logger.DebugContext(ctx, "api streaming client response", "serviceName", serviceName, "rpcName", "StreamAgentMessages")
		return err
	}, opts...)
	if err != nil {
		return nil, err
	}
	return resp, nil
}