Method Shutdown

pubsub/pubsub.go:281–306

Shutdown flushes pending message sends and disconnects the Topic. It only returns after all pending messages have been sent.

(ctx context.Context)

// Shutdown flushes pending message sends and disconnects the Topic.
// It only returns after all pending messages have been sent.
func (t *Topic) Shutdown(ctx context.Context) (err error) {
	ctx, span := t.tracer.Start(ctx, "Topic.Shutdown")
	defer func() { t.tracer.End(ctx, span, err) }()

	t.mu.Lock()
	if errors.Is(t.err, errTopicShutdown) {
		defer t.mu.Unlock()
		return t.err
	}
	t.err = errTopicShutdown
	t.mu.Unlock()
	c := make(chan struct{})
	go func() {
		defer close(c)
		t.batcher.Shutdown()
	}()
	select {
	case <-ctx.Done():
	case <-c:
	}
	t.cancel()
	if err := t.driver.Close(); err != nil {
		return wrapError(t.driver, err)
	}
	return ctx.Err()
}

// As converts i to driver-specific types.
// See https://gocloud.dev/concepts/as/ for background information, the "As"