diff --git a/services/streaming/service.go b/services/streaming/service.go
index 30a11c6a5..f9159e43a 100644
--- a/services/streaming/service.go
+++ b/services/streaming/service.go
@@ -74,20 +74,23 @@ func (s *service) Stream(srv api.Streaming_StreamServer) error {
 	if err != nil {
 		return err
 	}
-	if err := srv.Send(protobuf.FromAny(response)); err != nil {
-		return err
-	}
 
 	cc := make(chan struct{})
 	ss := &serviceStream{
 		s:  srv,
 		cc: cc,
 	}
+
 	log.G(srv.Context()).WithField("stream", i.ID).Debug("registering stream")
 	if err := s.manager.Register(srv.Context(), i.ID, ss); err != nil {
 		return err
 	}
 
+	// Send response packet after registering stream
+	if err := srv.Send(protobuf.FromAny(response)); err != nil {
+		return err
+	}
+
 	select {
 	case <-srv.Context().Done():
 		// TODO: Should return error if not cancelled?