make worker private

Author: briansorahan

osc.go

@@ -137,16 +137,16 @@ func serve(r readSender, numWorkers int, exactMatch bool, dispatcher Dispatcher)
 	}
 	var (
 		errChan = make(chan error)
-		ready   = make(chan Worker, numWorkers)
+		ready   = make(chan worker, numWorkers)
 	)
 	for i := 0; i < numWorkers; i++ {
-		go Worker{
+		go worker{
 			DataChan:   make(chan Incoming),
 			Dispatcher: dispatcher,
 			ErrChan:    errChan,
 			Ready:      ready,
 			ExactMatch: exactMatch,
-		}.Run()
+		}.run()
 	}
 	go workerLoop(r, ready, errChan)
 
@@ -161,7 +161,7 @@ func serve(r readSender, numWorkers int, exactMatch bool, dispatcher Dispatcher)
 	return nil
 }
 
-func workerLoop(r readSender, ready chan Worker, errChan chan error) {
+func workerLoop(r readSender, ready chan worker, errChan chan error) {
 	for {
 		data := make([]byte, bufSize)
 		_, sender, err := r.read(data)

worker.go

@@ -4,17 +4,17 @@ import (
 	"github.com/pkg/errors"
 )
 
-// Worker is a worker who can process OSC messages.
-type Worker struct {
+// worker is a worker who can process OSC messages.
+type worker struct {
 	DataChan   chan Incoming
 	Dispatcher Dispatcher
 	ErrChan    chan error
-	Ready      chan<- Worker
+	Ready      chan<- worker
 	ExactMatch bool
 }
 
-// Run runs the worker.
-func (w Worker) Run() {
+// run runs the worker.
+func (w worker) run() {
 	w.Ready <- w
 
 DataLoop:

worker_test.go

@@ -11,9 +11,9 @@ func TestWorkerRun(t *testing.T) {
 	var (
 		data  = make(chan Incoming)
 		errch = make(chan error)
-		ready = make(chan Worker)
+		ready = make(chan worker)
 	)
-	worker := Worker{
+	wrk := worker{
 		DataChan:   data,
 		Dispatcher: errorDispatcher{},
 		ErrChan:    errch,
@@ -23,7 +23,7 @@ func TestWorkerRun(t *testing.T) {
 	defer close(data)
 
 	// Run the worker goroutine.
-	go worker.Run()
+	go wrk.run()
 
 	// Wait for the worker to signal that it is ready.
 	select {