increased input buffer to improve performance

This commit is contained in:
harshabose
2025-06-01 16:27:51 +05:30
parent 2da9dd56cc
commit f6eabae72a

View File

@@ -20,7 +20,7 @@ func CreateChannelBuffer[T any](ctx context.Context, size int, pool Pool[T]) *Ch
buffer := &ChannelBuffer[T]{
pool: pool,
bufferChannel: make(chan *T, size),
inputBuffer: make(chan *T),
inputBuffer: make(chan *T, size),
closed: false,
ctx: ctx,
}