Add method which allows to remove a receiver

Description

Related Issue

Motivation and Context

How Has This Been Tested?

Screenshots (if appropriate):

Types of changes

• Bug fix (non-breaking change which fixes an issue)
• New feature (non-breaking change which adds functionality)
• Breaking change (fix or feature that would cause existing functionality to change)

Checklist:

• My code follows the code style of this project.
• My change requires a change to the documentation.
• I have updated the documentation accordingly.
• I have read the CONTRIBUTING document.
• I have added tests to cover my changes.
• All new and existing tests passed.

goKMS/kms/akms/server/receiver.go

@@ -5,6 +5,7 @@ import (
 	"sync"
 
 	"github.com/google/uuid"
+	"github.com/sirupsen/logrus"
 )
 
 type Receiver struct {
@@ -22,12 +23,27 @@ func (r *Receiver) RequestReceiverChannel(pathId uuid.UUID) (<-chan struct{}, er
 	return newSubChan, nil
 }
 
+func (r *Receiver) RemoveReceiver(pathId uuid.UUID) error {
+	r.mu.Lock()
+	defer r.mu.Unlock()
+
+	if channel, ok := r.receivers[pathId]; ok {
+		close(channel)
+		delete(r.receivers, pathId)
+	} else {
+		return fmt.Errorf("There are no active subscribers for pathId: %s", pathId)
+	}
+
+	logrus.Debugf("Current active receivers after removing receiver for pathId: %s; Receivers: %v", pathId, r.receivers)
+	return nil
+}
+
 func (r *Receiver) InformReceiver(pathId uuid.UUID) error {
 	r.mu.RLock()
 	defer r.mu.RUnlock()
 
 	if receiver, ok := r.receivers[pathId]; ok {
-		receiver <- struct{}{}
+		go func() { receiver <- struct{}{} }()
 	} else {
 		return fmt.Errorf("There are no active subscribers for pathId: %s", pathId)
 	}