fix: add cancel for request_channel (#120)

rsocket · Feb 16, 2022 · f0ecbcf · f0ecbcf
1 parent 4f58f3c
commit f0ecbcf
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/internal/socket/duplex.go b/internal/socket/duplex.go
@@ -2,6 +2,7 @@ package socket
 
 import (
 	"context"
+	"fmt"
 	"runtime"
 	"sync"
 	"time"
@@ -816,8 +817,10 @@ func (dc *DuplexConnection) onFrameCancel(frame core.BufferedFrame) (err error)
 		vv.su.Cancel()
 	case requestStreamCallbackReverse:
 		vv.su.Cancel()
+	case requestChannelCallback:
+		vv.snd.Cancel()
 	default:
-		panic("cannot cancel")
+		panic(fmt.Sprintf("cannot cancel for callback type %T!", vv))
 	}
 
 	return