Move notifier code to async package.

async/notifier.go

@@ -19,7 +19,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-package signaling
+package async
 
 import (
 	"context"

async/notifier_test.go

@@ -19,7 +19,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-package signaling
+package async
 
 import (
 	"context"

async/single_notifier.go

@@ -19,7 +19,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-package signaling
+package async
 
 import (
 	"context"

async/single_notifier_test.go

@@ -19,7 +19,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-package signaling
+package async
 
 import (
 	"context"

mcu_janus.go

@@ -35,6 +35,7 @@ import (
 	"github.com/notedit/janus-go"
 
 	"github.com/strukturag/nextcloud-spreed-signaling/api"
+	"github.com/strukturag/nextcloud-spreed-signaling/async"
 	"github.com/strukturag/nextcloud-spreed-signaling/internal"
 	"github.com/strukturag/nextcloud-spreed-signaling/log"
 )
@@ -256,8 +257,8 @@ type mcuJanus struct {
 
 	// +checklocks:mu
 	publishers         map[StreamId]*mcuJanusPublisher
-	publisherCreated   Notifier
-	publisherConnected Notifier
+	publisherCreated   async.Notifier
+	publisherConnected async.Notifier
 	// +checklocks:mu
 	remotePublishers map[StreamId]*mcuJanusRemotePublisher
 

mcu_proxy.go

@@ -371,7 +371,7 @@ type mcuProxyConnection struct {
 	trackClose        atomic.Bool
 	temporary         atomic.Bool
 
-	connectedNotifier SingleNotifier
+	connectedNotifier async.SingleNotifier
 
 	msgId      atomic.Int64
 	helloMsgId string