@@ -13,5 +13,5 @@ public interface IRealtimeHub
 
     IRealTimeCompletion Completer { get; }
 
-    Task ConnectToModel(Func<string, Task> responseToUser);
+    Task ConnectToModel(Func<string, Task>? responseToUser = null, Func<string, Task>? init = null);
 }
@@ -21,7 +21,7 @@ public RealtimeHub(IServiceProvider services, ILogger<RealtimeHub> logger)
         _logger = logger;
     }
 
-    public async Task ConnectToModel(Func<string, Task> responseToUser)
+    public async Task ConnectToModel(Func<string, Task>? responseToUser = null, Func<string, Task>? init = null)
     {
         var hookProvider = _services.GetService<ConversationHookProvider>();
         var convService = _services.GetRequiredService<IConversationService>();
@@ -57,13 +57,13 @@ await _completer.Connect(_conn,
                 // Not TriggerModelInference, waiting for user utter.
                 var instruction = await _completer.UpdateSession(_conn);
                 var data = _conn.OnModelReady();
-                await responseToUser(data);
+                await (init?.Invoke(data) ?? Task.CompletedTask);
                 await HookEmitter.Emit<IRealtimeHook>(_services, async hook => await hook.OnModelReady(agent, _completer));
             },
             onModelAudioDeltaReceived: async (audioDeltaData, itemId) =>
             {
                 var data = _conn.OnModelMessageReceived(audioDeltaData);
-                await responseToUser(data);
+                await (responseToUser?.Invoke(data) ?? Task.CompletedTask);
 
                 // If this is the first delta of a new response, set the start timestamp
                 if (!_conn.ResponseStartTimestamp.HasValue)
@@ -83,7 +83,7 @@ await _completer.Connect(_conn,
             onModelAudioResponseDone: async () =>
             {
                 var data = _conn.OnModelAudioResponseDone();
-                await responseToUser(data);
+                await (responseToUser?.Invoke(data) ?? Task.CompletedTask);
             }, 
             onAudioTranscriptDone: async transcript =>
             {
@@ -148,7 +148,7 @@ await _completer.Connect(_conn,
                     _conn.ResetResponseState();
 
                     var data = _conn.OnModelUserInterrupted();
-                    await responseToUser(data);
+                    await (responseToUser?.Invoke(data) ?? Task.CompletedTask);
                 }
             });
     }
Original file line number	Diff line number	Diff line change
`@@ -13,5 +13,5 @@ public interface IRealtimeHub`
`13`	`13`
`14`	`14`	`IRealTimeCompletion Completer { get; }`
`15`	`15`
`16`		`- Task ConnectToModel(Func<string, Task> responseToUser);`
	`16`	`+ Task ConnectToModel(Func<string, Task>? responseToUser = null, Func<string, Task>? init = null);`
`17`	`17`	`}`
Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@ public RealtimeHub(IServiceProvider services, ILogger<RealtimeHub> logger)`
`21`	`21`	`_logger = logger;`
`22`	`22`	`}`
`23`	`23`
`24`		`- public async Task ConnectToModel(Func<string, Task> responseToUser)`
	`24`	`+ public async Task ConnectToModel(Func<string, Task>? responseToUser = null, Func<string, Task>? init = null)`
`25`	`25`	`{`
`26`	`26`	`var hookProvider = _services.GetService<ConversationHookProvider>();`
`27`	`27`	`var convService = _services.GetRequiredService<IConversationService>();`
`@@ -57,13 +57,13 @@ await _completer.Connect(_conn,`
`57`	`57`	`// Not TriggerModelInference, waiting for user utter.`
`58`	`58`	`var instruction = await _completer.UpdateSession(_conn);`
`59`	`59`	`var data = _conn.OnModelReady();`
`60`		`- await responseToUser(data);`
	`60`	`+ await (init?.Invoke(data) ?? Task.CompletedTask);`
`61`	`61`	`await HookEmitter.Emit<IRealtimeHook>(_services, async hook => await hook.OnModelReady(agent, _completer));`
`62`	`62`	`},`
`63`	`63`	`onModelAudioDeltaReceived: async (audioDeltaData, itemId) =>`
`64`	`64`	`{`
`65`	`65`	`var data = _conn.OnModelMessageReceived(audioDeltaData);`
`66`		`- await responseToUser(data);`
	`66`	`+ await (responseToUser?.Invoke(data) ?? Task.CompletedTask);`
`67`	`67`
`68`	`68`	`// If this is the first delta of a new response, set the start timestamp`
`69`	`69`	`if (!_conn.ResponseStartTimestamp.HasValue)`
`@@ -83,7 +83,7 @@ await _completer.Connect(_conn,`
`83`	`83`	`onModelAudioResponseDone: async () =>`
`84`	`84`	`{`
`85`	`85`	`var data = _conn.OnModelAudioResponseDone();`
`86`		`- await responseToUser(data);`
	`86`	`+ await (responseToUser?.Invoke(data) ?? Task.CompletedTask);`
`87`	`87`	`},`
`88`	`88`	`onAudioTranscriptDone: async transcript =>`
`89`	`89`	`{`
`@@ -148,7 +148,7 @@ await _completer.Connect(_conn,`
`148`	`148`	`_conn.ResetResponseState();`
`149`	`149`
`150`	`150`	`var data = _conn.OnModelUserInterrupted();`
`151`		`- await responseToUser(data);`
	`151`	`+ await (responseToUser?.Invoke(data) ?? Task.CompletedTask);`
`152`	`152`	`}`
`153`	`153`	`});`
`154`	`154`	`}`