diff --git a/Sharp7.Rx/linqpad-samples/Create Notification.linq b/Sharp7.Rx/linqpad-samples/Create Notification.linq
index 57d9720..9357004 100644
--- a/Sharp7.Rx/linqpad-samples/Create Notification.linq	
+++ b/Sharp7.Rx/linqpad-samples/Create Notification.linq	
@@ -16,10 +16,7 @@ var cpuMpiAddress = 0;
 
 using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress);
 
-await plc.InitializeAsync();
-await plc.ConnectionState
-	.FirstAsync(c => c == Sharp7.Rx.Enums.ConnectionState.Connected)
-	.ToTask();
+await plc.InitializeConnection();
 
 "Connection established".Dump();
 
diff --git a/Sharp7.Rx/linqpad-samples/Establish connection.linq b/Sharp7.Rx/linqpad-samples/Establish connection.linq
index 33f6f69..8b96b56 100644
--- a/Sharp7.Rx/linqpad-samples/Establish connection.linq	
+++ b/Sharp7.Rx/linqpad-samples/Establish connection.linq	
@@ -18,7 +18,7 @@ var cpuMpiAddress = 0;
 using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress);
 
 // Initialize connection
-await plc.InitializeAsync();
+await plc.InitializeConnection();
 
 // wait for connection to be established
 await plc.ConnectionState
diff --git a/Sharp7.Rx/linqpad-samples/Multiple notifications.linq b/Sharp7.Rx/linqpad-samples/Multiple notifications.linq
index ec8db01..6078d74 100644
--- a/Sharp7.Rx/linqpad-samples/Multiple notifications.linq	
+++ b/Sharp7.Rx/linqpad-samples/Multiple notifications.linq	
@@ -18,10 +18,7 @@ using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress);
 
 plc.ConnectionState.Dump();
 
-await plc.InitializeAsync();
-await plc.ConnectionState
-	.FirstAsync(c => c == Sharp7.Rx.Enums.ConnectionState.Connected)
-	.ToTask();
+await plc.InitializeConnection();
 
 // create an IObservable
 plc.CreateNotification<short>($"DB{db}.Int6", Sharp7.Rx.Enums.TransmissionMode.OnChange).Dump("Int 6");
diff --git a/Sharp7.Rx/linqpad-samples/Write and read value.linq b/Sharp7.Rx/linqpad-samples/Write and read value.linq
index ee5780e..302bb3a 100644
--- a/Sharp7.Rx/linqpad-samples/Write and read value.linq	
+++ b/Sharp7.Rx/linqpad-samples/Write and read value.linq	
@@ -16,10 +16,7 @@ var cpuMpiAddress = 0;
 
 using var plc = new Sharp7Plc(ip, rackNumber, cpuMpiAddress);
 
-await plc.InitializeAsync();
-await plc.ConnectionState
-	.FirstAsync(c => c == Sharp7.Rx.Enums.ConnectionState.Connected)
-	.ToTask();
+await plc.InitializeConnection();
 
 "Connection established".Dump();