diff --git a/sinks/adsb-ws/input.go b/sinks/adsb-ws/input.go
new file mode 100644
index 0000000..7dbe818
--- /dev/null
+++ b/sinks/adsb-ws/input.go
@@ -0,0 +1,18 @@
+package main
+
+import (
+	"log"
+	"os"
+)
+
+func readInput() {
+	for {
+		b1 := make([]byte, 256)
+		n, err := os.Stdin.Read(b1)
+		if err != nil {
+			log.Printf("error: %v", err)
+			break
+		}
+		log.Println(n, b1)
+	}
+}
diff --git a/sinks/adsb-ws/main.go b/sinks/adsb-ws/main.go
index 522f35a..8737edc 100644
--- a/sinks/adsb-ws/main.go
+++ b/sinks/adsb-ws/main.go
@@ -10,6 +10,7 @@ var addr = flag.String("addr", ":8080", "http service address")
 
 func main() {
 	flag.Parse()
+	go readInput()
 	http.HandleFunc("/stream", serveStream)
 	err := http.ListenAndServe(*addr, nil)
 	if err != nil {