openSubscription returns a driver.Subscription.
(client *raw.SubscriberClient, subscriptionPath string, opts *SubscriptionOptions)
| 514 | |
| 515 | // openSubscription returns a driver.Subscription. |
| 516 | func openSubscription(client *raw.SubscriberClient, subscriptionPath string, opts *SubscriptionOptions) *subscription { |
| 517 | if opts == nil { |
| 518 | opts = &SubscriptionOptions{} |
| 519 | } |
| 520 | if opts.MaxBatchSize == 0 { |
| 521 | opts.MaxBatchSize = defaultRecvBatcherOpts.MaxBatchSize |
| 522 | } |
| 523 | return &subscription{client, subscriptionPath, opts} |
| 524 | } |
| 525 | |
| 526 | // ReceiveBatch implements driver.Subscription.ReceiveBatch. |
| 527 | func (s *subscription) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) { |
no outgoing calls