rename to ofainin

Author: sjnam

README.md

@@ -1,4 +1,4 @@
-# Concurrent ordered processing
+# Ordered Fan-In
 You can use this `oproc` package when you want to speed up processing with goroutines
 while guaranteeing ordering.
 
@@ -13,14 +13,14 @@ import (
 	"math/rand"
 	"time"
 
-	"github.com/sjnam/oproc"
+	"github.com/sjnam/ofanin"
 )
 
 func main() {
 	ctx, cancel := context.WithCancel(context.TODO())
 	defer cancel()
 
-	my := oproc.NewOrderedProc[string /*input param*/, string /*output param*/](ctx)
+	my := ofanin.NewOrderedFanIn[string /*input param*/, string /*output param*/](ctx)
 	my.InputStream = func() <-chan string {
 		ch := make(chan string)
 		go func() {

examples/ctan/main.go

@@ -7,7 +7,7 @@ import (
 	"log"
 	"net/http"
 
-	"github.com/sjnam/oproc"
+	"github.com/sjnam/ofanin"
 )
 
 type item struct {
@@ -26,7 +26,7 @@ func main() {
 	ctx, cancel := context.WithCancel(context.TODO())
 	defer cancel()
 
-	my := oproc.NewOrderedProc[item /*input param*/, item /*output param*/](ctx)
+	my := ofanin.NewOrderedFanIn[item /*input param*/, item /*output param*/](ctx)
 	my.InputStream = func() <-chan item {
 		valStream := make(chan item)
 		go func() {

examples/ordered/main.go

@@ -6,14 +6,14 @@ import (
 	"math/rand"
 	"time"
 
-	"github.com/sjnam/oproc"
+	"github.com/sjnam/ofanin"
 )
 
 func main() {
 	ctx, cancel := context.WithCancel(context.TODO())
 	defer cancel()
 
-	my := oproc.NewOrderedProc[string /*input param*/, string /*output param*/](ctx)
+	my := ofanin.NewOrderedFanIn[string /*input param*/, string /*output param*/](ctx)
 	my.InputStream = func() <-chan string {
 		ch := make(chan string)
 		go func() {

go.mod

@@ -1,3 +1,3 @@
-module github.com/sjnam/oproc
+module github.com/sjnam/ofanin
 
 go 1.23.4

oproc.go ofanin.go

@@ -1,25 +1,25 @@
-package oproc
+package ofanin
 
 import (
 	"context"
 	"runtime"
 )
 
-type OrderedProc[TI /*input param type*/, TO /*output param type*/ any] struct {
+type OrderedFanIn[TI /*input param type*/, TO /*output param type*/ any] struct {
 	Ctx         context.Context
 	InputStream <-chan TI
 	DoWork      func(TI) TO
 	Size        int
 }
 
-func NewOrderedProc[TI, TO any](ctx context.Context) *OrderedProc[TI, TO] {
-	return &OrderedProc[TI, TO]{
+func NewOrderedFanIn[TI, TO any](ctx context.Context) *OrderedFanIn[TI, TO] {
+	return &OrderedFanIn[TI, TO]{
 		Ctx:  ctx,
 		Size: runtime.NumCPU(),
 	}
 }
 
-func (o *OrderedProc[TI, TO]) Process() <-chan TO {
+func (o *OrderedFanIn[TI, TO]) Process() <-chan TO {
 	orDone := func(c <-chan TO) <-chan TO {
 		ch := make(chan TO)
 		go func() {

oproc_test.go ofanin_test.go

@@ -1,15 +1,15 @@
-package oproc
+package ofanin
 
 import (
 	"context"
 	"fmt"
 )
 
-func ExampleOrderedProc() {
+func ExampleOrderedFanIn() {
 	ctx, cancel := context.WithCancel(context.TODO())
 	defer cancel()
 
-	my := NewOrderedProc[string /*input param*/, string /*output param*/](ctx)
+	my := NewOrderedFanIn[string /*input param*/, string /*output param*/](ctx)
 	my.InputStream = func() <-chan string {
 		ch := make(chan string)
 		go func() {