mixer: add packet receiver

1 files changed, 15 insertions, 1 deletions

diff --git a/pkg/mixer/mixer.go b/pkg/mixer/mixer.go
index 8dfda64..fb575d6 100644
--- a/pkg/mixer/mixer.go
+++ b/pkg/mixer/mixer.go
@@ -24,6 +24,7 @@ package mixer
 
 import (
 	"errors"
+	"log"
 	"strings"
 
 	"github.com/scgolang/midi"
@@ -73,11 +74,24 @@ func NewMixer(c Config) (*Mixer, error) {
 		return nil, err
 	}
 
+	m.DevIn.QueueSize = 100
+	m.DevOut.QueueSize = 100
 	return m, nil
 }
 
 func (m *Mixer) Init() error {
-	// TODO: sync state
+	ch, err := m.DevIn.Packets()
+	if err != nil {
+		return err
+	}
+
+	go func() {
+		for {
+			p := <-ch
+			log.Printf("mixer: got packet: '%v'", p)
+			// TODO: send to subscribers
+		}
+	}()
 	return nil
 }