Update sdk/metric/pipeline.go

MrAlias · MadVikingGod · web-flow · commit db62d9e35512 · 2022-12-08T15:07:29.000-08:00
Co-authored-by: Aaron Clawson &lt;3766680+MadVikingGod@users.noreply.github.com&gt;
diff --git a/sdk/metric/pipeline.go b/sdk/metric/pipeline.go
@@ -96,7 +96,7 @@ func (p *pipeline) addSync(scope instrumentation.Scope, iSync instrumentSync) {
 }
 
 // addCallback registers a callback to be run when `produce()` is called.
-func (p *pipeline) addCallback(c callback) func() {
+func (p *pipeline) addCallback(c callback) (unregister func()) {
 	p.Lock()
 	defer p.Unlock()
 	e := p.callbacks.PushBack(c)

Original file line number	Diff line number	Diff line change
`@@ -96,7 +96,7 @@ func (p *pipeline) addSync(scope instrumentation.Scope, iSync instrumentSync) {`
`96`	`96`	`}`
`97`	`97`
`98`	`98`	// addCallback registers a callback to be run when `produce()` is called.
`99`		`-func (p *pipeline) addCallback(c callback) func() {`
	`99`	`+func (p *pipeline) addCallback(c callback) (unregister func()) {`
`100`	`100`	`p.Lock()`
`101`	`101`	`defer p.Unlock()`
`102`	`102`	`e := p.callbacks.PushBack(c)`