Skip to content

Commit edeba06

Browse files
Removed uint type conversion when making the chan
* BufferSize was changed to default to uint and no longer needs this type conversion * this was requested by the repo owner
1 parent cde5228 commit edeba06

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

pkg/outputs/nats_outputs/jetstream/jetstream_output.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ func (n *jetstreamOutput) Init(ctx context.Context, name string, cfg map[string]
137137
return err
138138
}
139139

140-
n.msgChan = make(chan *outputs.ProtoMsg, uint(n.Cfg.BufferSize))
140+
n.msgChan = make(chan *outputs.ProtoMsg, n.Cfg.BufferSize)
141141
initMetrics()
142142
n.mo = &formatters.MarshalOptions{
143143
Format: n.Cfg.Format,

pkg/outputs/nats_outputs/nats/nats_output.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ func (n *NatsOutput) Init(ctx context.Context, name string, cfg map[string]inter
146146
return err
147147
}
148148

149-
n.msgChan = make(chan *outputs.ProtoMsg, uint(n.Cfg.BufferSize))
149+
n.msgChan = make(chan *outputs.ProtoMsg, n.Cfg.BufferSize)
150150
initMetrics()
151151
n.mo = &formatters.MarshalOptions{
152152
Format: n.Cfg.Format,

0 commit comments

Comments
 (0)