Skip to content

Commit

Permalink
apply PR feedback
Browse files Browse the repository at this point in the history
  • Loading branch information
paupm committed Aug 28, 2024
1 parent 23f12e5 commit 62390b1
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pkg/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,14 @@ func main() {
msgCh2 := make(chan messages.Message, bufLen)

bufLen = GetBufferLength("ACK_BUFFER_LENGTH")
ackCh1 := make(chan messages.Ack, bufLen)
ackCh := make(chan messages.Ack, bufLen)

reader, err := readers.NewReader(msgCh1, ackCh1)
reader, err := readers.NewReader(msgCh1, ackCh)
if err != nil {
panic(err)
}

writer, err := writers.NewWriter(msgCh2, ackCh1)
writer, err := writers.NewWriter(msgCh2, ackCh)
if err != nil {
panic(err)
}
Expand Down

0 comments on commit 62390b1

Please sign in to comment.