diff --git a/input_dummy.go b/input_dummy.go index 5360d31..cbf9586 100644 --- a/input_dummy.go +++ b/input_dummy.go @@ -36,16 +36,13 @@ func (i *DummyInput) PluginRead() (*Message, error) { func (i *DummyInput) emit() { ticker := time.NewTicker(time.Second) - for { - select { - case <-ticker.C: - uuid := uuid() - reqh := payloadHeader(RequestPayload, uuid, time.Now().UnixNano(), -1) - i.data <- append(reqh, []byte("GET / HTTP/1.1\r\nHost: www.w3.org\r\nUser-Agent: Go 1.1 package http\r\nAccept-Encoding: gzip\r\n\r\n")...) + for range ticker.C { + uuid := uuid() + reqh := payloadHeader(RequestPayload, uuid, time.Now().UnixNano(), -1) + i.data <- append(reqh, []byte("GET / HTTP/1.1\r\nHost: www.w3.org\r\nUser-Agent: Go 1.1 package http\r\nAccept-Encoding: gzip\r\n\r\n")...) - resh := payloadHeader(ResponsePayload, uuid, time.Now().UnixNano()+1, 1) - i.data <- append(resh, []byte("HTTP/1.1 200 OK\r\nContent-Length: 0\r\n\r\n")...) - } + resh := payloadHeader(ResponsePayload, uuid, time.Now().UnixNano()+1, 1) + i.data <- append(resh, []byte("HTTP/1.1 200 OK\r\nContent-Length: 0\r\n\r\n")...) } }