Commitdbc9515

committed

remove mutex on sub close

1 parentf0b8796 commitdbc9515Copy full SHA for dbc9515

File tree

-2

lines changed

-2

lines changed

Lines changed: 0 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -110,8 +110,6 @@ func (s *sub) start(ctx context.Context) (err error) {`
`110`	`110`	`func (s*sub)Close()error {`
`111`	`111`	`s.cancelFn()`
`112`	`112`
`113`		`-s.mu.Lock()`
`114`		`-defers.mu.Unlock()`
`115`	`113`	`ifs.psCancelFn!=nil {`
`116`	`114`	`s.psCancelFn()`
`117`	`115`	`}`

Comments

(0)