sinks/adsb-ws/input.go

package main

import (
	"bufio"
	"log"
	"os"
)

func readInput() {
	r := bufio.NewReader(os.Stdin)
	for {
		line, err := r.ReadBytes('\n')
		if err != nil {
			log.Fatal("Input read error: ", err)
		}
		h.broadcast <- line
	}
}
Read input from stdin, push to stderr. Baby's first go 2016-03-10 17:07:44 -08:00			`package main`

			`import (`
More input parsing 2016-03-10 17:54:32 -08:00			`"bufio"`
Read input from stdin, push to stderr. Baby's first go 2016-03-10 17:07:44 -08:00			`"log"`
			`"os"`
			`)`

			`func readInput() {`
More input parsing 2016-03-10 17:54:32 -08:00			`r := bufio.NewReader(os.Stdin)`
Read input from stdin, push to stderr. Baby's first go 2016-03-10 17:07:44 -08:00			`for {`
Turn adsb-ws into a json repeater, rather than a protocol converter 2016-03-10 20:19:29 -08:00			`line, err := r.ReadBytes('\n')`
Actually parsing packets 2016-03-10 17:59:24 -08:00			`if err != nil {`
Turn adsb-ws into a json repeater, rather than a protocol converter 2016-03-10 20:19:29 -08:00			`log.Fatal("Input read error: ", err)`
Actually parsing packets 2016-03-10 17:59:24 -08:00			`}`
Turn adsb-ws into a json repeater, rather than a protocol converter 2016-03-10 20:19:29 -08:00			`h.broadcast <- line`
Read input from stdin, push to stderr. Baby's first go 2016-03-10 17:07:44 -08:00			`}`
			`}`