package main import ( "io" "log" "net" "sync" "testing" ) func TestTCPInput(t *testing.T) { wg := new(sync.WaitGroup) quit := make(chan int) input := NewTCPInput("127.0.0.1:0") output := NewTestOutput(func(data []byte) { wg.Done() }) Plugins.Inputs = []io.Reader{input} Plugins.Outputs = []io.Writer{output} go Start(quit) tcpAddr, err := net.ResolveTCPAddr("tcp", input.listener.Addr().String()) if err != nil { log.Fatal(err) } conn, err := net.DialTCP("tcp", nil, tcpAddr) if err != nil { log.Fatal(err) } msg := []byte("1 1 1\nGET / HTTP/1.1\r\n\r\n") for i := 0; i < 100; i++ { wg.Add(1) conn.Write(msg) conn.Write([]byte(payloadSeparator)) } wg.Wait() close(quit) }