udp start context

2021-03-31 18:32:27 +01:00 · 2021-03-31 18:32:27 +01:00 · 6d44a75138
commit 6d44a75138
parent 9a19ecd0d4
1 changed files with 5 additions and 1 deletions
--- a/udp/flow.go
+++ b/udp/flow.go
@ -111,10 +111,14 @@ func (f *InitiatedFlow) Reconnect(ctx context.Context) error {
 	go func() {
 		seq, err := f.congestion.Sequence(ctx)
 		if err != nil {
-
+			return
 		}

 		for !f.isAlive {
+			if ctx.Err() != nil {
+				return
+			}
+
 			p := Packet{
 				ack:  0,
 				nack: 0,