feat: adding ability to observe the creation of observable

src/Nullinside.Api.Common/Twitch/TwitchClientProxy.cs

@@ -67,6 +67,11 @@ public class TwitchClientProxy : ITwitchClientProxy {
   ///   The callback(s) to invoke when a channel receives a ban message.
   /// </summary>
   private Action<OnUserBannedArgs>? onUserBanReceived;
+
+  /// <summary>
+  ///   The callback(s) to invoke when a new instance is created.
+  /// </summary>
+  private static Action<TwitchClientProxy>? onInstanceCreated;
 
   /// <summary>
   ///   The web socket to connect to twitch chat with.
@@ -93,6 +98,7 @@ public static TwitchClientProxy Instance {
     get {
       if (null == instance) {
         instance = new TwitchClientProxy();
+        onInstanceCreated?.Invoke(instance);
       }
 
       return instance;
@@ -164,6 +170,17 @@ public async Task AddMessageCallback(string channel, Action<OnMessageReceivedArg
   public void RemoveMessageCallback(Action<OnMessageReceivedArgs> callback) {
     onMessageReceived -= callback;
   }
+
+  /// <inheritdoc />
+  public void AddInstanceCallback(Action<TwitchClientProxy> callback) {
+    onInstanceCreated -= callback;
+    onInstanceCreated += callback;
+  }
+
+  /// <inheritdoc />
+  public void RemoveInstanceCallback(Action<TwitchClientProxy> callback) {
+    onInstanceCreated -= callback;
+  }
 
   /// <inheritdoc />
   public async Task AddBannedCallback(string channel, Action<OnUserBannedArgs> callback) {
@@ -408,8 +425,11 @@ private void TwitchChatClient_OnUserBanned(object? sender, OnUserBannedArgs e) {
   /// <param name="disposing">True if called directly, false if called from the destructor.</param>
   protected virtual void Dispose(bool disposing) {
     if (disposing) {
+      client?.Disconnect();
       twitchChatClientReconnect?.Dispose();
       socket?.Dispose();
     }
+
+    instance = null;
   }
 }