From 809770ae4430723e76533807ede23ee4c9fbbf4f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E3=81=A8=E3=83=BC=E3=81=B5=E3=81=A8=E3=81=B5?= Date: Mon, 10 Feb 2020 18:29:17 +0900 Subject: [PATCH] =?UTF-8?q?=E3=83=AA=E3=82=AF=E3=82=A8=E3=82=B9=E3=83=88?= =?UTF-8?q?=E3=83=AD=E3=82=B0=E5=91=A8=E3=82=8A=E3=81=A7=E3=81=AE=E3=82=A8?= =?UTF-8?q?=E3=83=A9=E3=83=BC=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/transport/transport.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/transport/transport.go b/server/transport/transport.go index 49b6029..36474dc 100644 --- a/server/transport/transport.go +++ b/server/transport/transport.go @@ -24,6 +24,9 @@ func (t *myTransport) RoundTrip(req *http.Request) (*http.Response, error) { elapsed := time.Since(start) log.Println("Response Time:", elapsed.Nanoseconds()) - pubsub.AccessEvent.Pub(pubsub.Access{req, response, elapsed}) + go func() { + <-req.Context().Done() + pubsub.AccessEvent.Pub(pubsub.Access{req, response, elapsed}) + }() return response, nil }