Skip to content

Commit

Permalink
remove unused concurrentBuffer method
Browse files Browse the repository at this point in the history
  • Loading branch information
amanakin committed May 27, 2024
1 parent 3593215 commit a5b9505
Showing 1 changed file with 0 additions and 6 deletions.
6 changes: 0 additions & 6 deletions sdk/log/batch_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,12 +29,6 @@ type concurrentBuffer struct {
m sync.Mutex
}

func (b *concurrentBuffer) Read(p []byte) (n int, err error) {
b.m.Lock()
defer b.m.Unlock()
return b.b.Read(p)
}

func (b *concurrentBuffer) Write(p []byte) (n int, err error) {
b.m.Lock()
defer b.m.Unlock()
Expand Down

0 comments on commit a5b9505

Please sign in to comment.