From a14cc2f077e62150516ce3aeeca5366d54f2794b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=97=BA=E6=B1=AA?= <2246521484@qq.com> Date: Tue, 29 Mar 2022 01:16:54 +0800 Subject: [PATCH] Update input_dummy.go (#1070) make code cleaner --- input_dummy.go | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) 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")...) } }