Initial version (without timeout)

Author: floatdrop

.github/workflows/ci.yaml

@@ -0,0 +1,21 @@
+name: CI
+
+on: [push]
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v4
+      - name: Setup Go
+        uses: actions/setup-go@v5
+        with:
+          go-version: '1.24'
+      - name: Install dependencies
+        run: go get .
+      - name: Build
+        run: go build -v ./...
+      - name: Test with the Go CLI
+        run: go test
+        

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2025 Vsevolod Strukchinsky
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,50 @@
+# BatChan
+
+[![CI](https://github.com/floatdrop/batchan/actions/workflows/ci.yaml/badge.svg)](https://github.com/floatdrop/batchan/actions/workflows/ci.yaml)
+[![Go Report Card](https://goreportcard.com/badge/github.com/floatdrop/batchan)](https://goreportcard.com/report/github.com/floatdrop/batchan)
+[![Go Reference](https://pkg.go.dev/badge/github.com/floatdrop/batchan.svg)](https://pkg.go.dev/github.com/floatdrop/batchan)
+[![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT)
+
+## Installation
+
+```bash
+go get github.com/floatdrop/batchan
+```
+
+## Usage
+
+```go
+package main
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/floatdrop/batchan"
+)
+
+func main() {
+	input := make(chan string, 5)
+	batches := batchan.New(input, 3)
+
+	go func() {
+		inputs := []string{"A", "B", "C", "D", "E"}
+		for _, v := range inputs {
+			input <- v
+		}
+		close(input)
+	}()
+
+	for v := range batches {
+		fmt.Println("Got:", v)
+	}
+
+	// Output:
+	// Got: [A B C]
+	// Got: [D E]
+}
+```
+
+## License
+
+This project is licensed under the MIT License - see the [LICENSE](LICENSE) file for details.

batchan.go

@@ -0,0 +1,29 @@
+package batchan
+
+func New[T any](in <-chan T, size int) <-chan []T {
+	out := make(chan []T)
+
+	go func() {
+		defer close(out)
+
+		var currentBatch []T
+
+		flush := func() {
+			if len(currentBatch) > 0 {
+				out <- currentBatch
+				currentBatch = nil
+			}
+		}
+
+		for t := range in {
+			if len(currentBatch) >= size {
+				flush()
+			}
+			currentBatch = append(currentBatch, t)
+		}
+
+		flush()
+	}()
+
+	return out
+}

batchan_test.go

@@ -0,0 +1 @@
+package batchan

example_test.go

@@ -0,0 +1,28 @@
+package batchan_test
+
+import (
+	"fmt"
+
+	"github.com/floatdrop/batchan"
+)
+
+func ExampleNew() {
+	input := make(chan string, 5)
+	batches := batchan.New(input, 3)
+
+	go func() {
+		inputs := []string{"A", "B", "C", "D", "E"}
+		for _, v := range inputs {
+			input <- v
+		}
+		close(input)
+	}()
+
+	for v := range batches {
+		fmt.Println("Got:", v)
+	}
+
+	// Output:
+	// Got: [A B C]
+	// Got: [D E]
+}

go.mod

@@ -0,0 +1,3 @@
+module github.com/floatdrop/batchan
+
+go 1.23