diff --git a/drpcmanager/manager.go b/drpcmanager/manager.go
index 5723abe..9eb3812 100644
--- a/drpcmanager/manager.go
+++ b/drpcmanager/manager.go
@@ -291,7 +291,8 @@ func (m *Manager) manageStream(ctx context.Context, stream *drpcstream.Stream) {
 
 	select {
 	case <-m.sigs.term.Signal():
-		stream.Cancel(context.Canceled)
+		err, _ := m.sigs.term.Get()
+		stream.Cancel(err)
 		<-m.sterm
 		return