We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 207f4e2 commit 93e569fCopy full SHA for 93e569f
proxy/proxy.go
@@ -288,22 +288,14 @@ func (p *Proxy) proxyStream(
288
return err
289
}
290
connectSpan.End()
291
+ defer originConn.Close()
292
293
encodedSpans := tr.GetSpans()
294
295
if err := rwa.AckConnection(encodedSpans); err != nil {
296
297
298
- streamCtx, cancel := context.WithCancel(ctx)
299
- defer cancel()
300
-
301
- go func() {
302
- // streamCtx is done if req is cancelled or if Stream returns
303
- <-streamCtx.Done()
304
- originConn.Close()
305
- }()
306
307
originConn.Stream(ctx, rwa, p.log)
308
return nil
309
0 commit comments