From 1fd315a1a55b9afd721fe096a6cea65bcb066dbb Mon Sep 17 00:00:00 2001
From: Calvin Wilkinson <85414302+CalvinWilkinson@users.noreply.github.com>
Date: Mon, 22 Jan 2024 17:55:26 +0000
Subject: [PATCH] =?UTF-8?q?=F0=9F=9A=A7Improve=20subscriptions=20and=20sub?=
 =?UTF-8?q?scription=20ids=20(#191)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

* Start work for issue #187

* refactor!: renamed method parameters to id

* perf: cleanup and improve perf project

* config: cleanup and improve solution configs

asdf

* ide: add word to dictionary for vscode users

* ci: add deno permission

* ide: update run/debug configs for rider

* perf: refactored array check for to use TrueForAll instead of All

* refactor!: change the Subscriptions property type

* perf: improve perf of push reactable push method

* perf: improve perf of pull reactable pull method

* chore: suppress warning

* ide: suppress warning in solution level editor config

* chore: add using statements

* chore: perf project improvements

* perf: setup and collect perf data on non directional push reactable

* perf: improve perf of push & pull reactable PushPull method

* config: create run/debug config for push pull reactable perf test

* perf: setup and collect perf data on two way push pull reactable

* perf: adjust table

* chore: move error notification processing to base class

* fix: fix error processing in the two way push pull reactable

* fix: fix error processing in the one way pull reactable

* test: add tests

* refactor: simple code layout changes

* tests: add and improve tests

* ide,test,config: exclude samples project from code coverage results

* cleanup: remove unused usings

* fix: fix issue with pull notification being allowed after disposal

* fix: fix issue with push pull notification being allowed after disposal

* perf: improve perf of on error processing

* perf: improve perf of unsubscribe process

* refactor!: swapped the parameters for the 'Push' and 'PushPull' methods

* docs: update param name in readme code block
---
 .editorconfig                                 |  1 +
 .github/workflows/sync-bot.yml                |  2 +-
 .run/CarbonatePerfTests.run.xml               |  6 +-
 .run/Samples.run.xml                          |  8 +-
 .vscode/settings.json                         |  1 +
 Carbonate.sln                                 | 74 ++++++++++++-------
 Carbonate.sln.DotSettings                     |  1 +
 Carbonate/Carbonate.csproj                    |  2 +-
 Carbonate/Core/IReactable.cs                  |  3 +-
 Carbonate/Core/SubscriptionUnsubscriber.cs    |  5 +-
 Carbonate/Fluent/SubscriptionBuilder.cs       |  8 +-
 Carbonate/NonDirectional/IPushable.cs         |  6 +-
 Carbonate/NonDirectional/PushReactable.cs     | 61 ++-------------
 Carbonate/OneWay/IPullable.cs                 |  6 +-
 Carbonate/OneWay/IPushable.cs                 |  6 +-
 Carbonate/OneWay/PullReactable.cs             | 28 ++++---
 Carbonate/OneWay/PushReactable.cs             | 61 ++-------------
 Carbonate/ReactableBase.cs                    | 74 ++++++++++---------
 Carbonate/SubscriptionBase.cs                 |  2 +-
 Carbonate/TwoWay/IPushablePullable.cs         |  6 +-
 Carbonate/TwoWay/PushPullReactable.cs         | 25 +++++--
 .../TwoWay/ReceiveRespondSubscription.cs      |  2 +-
 README.md                                     |  2 +-
 .../Samples/OneWayWithoutFluentApiSample.cs   |  2 +-
 Samples/Samples/Program.cs                    |  2 +
 Samples/Samples/Samples.csproj                |  2 +
 Samples/Samples/TwoWayWithoutFluentApi.cs     |  8 +-
 .../CarbonateIntegrationTests.csproj          |  2 +-
 ...ableWithoutDataGoingIn_IntegrationTests.cs |  4 +-
 ...hPullReactableWithData_IntegrationTests.cs |  2 +-
 .../Benchmarks/NonDir_PushReactable_Class.cs  | 40 ++++++++++
 .../Benchmarks/OneWay_PullReactable_Class.cs  | 60 +++++++++++++++
 .../Benchmarks/OneWay_PushReactable_Class.cs  | 60 +++++++++++++++
 .../Benchmarks/PullReactable_Class.cs         | 50 -------------
 .../TwoWay_PushPullReactable_Class.cs         | 60 +++++++++++++++
 .../CarbonatePerfTests.csproj                 | 17 ++++-
 Testing/CarbonatePerfTests/DataItemResult.cs  | 16 ----
 Testing/CarbonatePerfTests/DataResult.cs      | 16 ----
 Testing/CarbonatePerfTests/Ids.cs             | 16 ----
 .../MemPerfs/MemPerfRunner.cs                 | 57 --------------
 .../MemPerfs/PerfScenarios.cs                 | 26 -------
 .../PrefResults/NonDirPushreactable.md        | 23 ++++++
 .../PrefResults/OneWayPullReactable.md        | 30 ++++++++
 .../PrefResults/OneWayPushReactable.md        | 30 ++++++++
 .../PrefResults/TwoWayPushPullReactable.md    | 30 ++++++++
 Testing/CarbonatePerfTests/Program.cs         | 64 +++++++++-------
 Testing/CarbonatePerfTests/PtrDataPuller.cs   | 28 -------
 Testing/CarbonatePerfTests/PtrDataStore.cs    | 44 -----------
 .../CarbonatePerfTests/StructDataPuller.cs    | 22 ------
 Testing/CarbonatePerfTests/StructDataStore.cs | 37 ----------
 Testing/CarbonatePerfTests/StructItem.cs      |  2 -
 Testing/CarbonateTests/CarbonateTests.csproj  |  2 +-
 .../Fluent/ReactableBuilderTests.cs           | 36 +++++++++
 .../Fluent/SubscriptionBuilderTests.cs        | 36 +++++++++
 .../OneWay/PullReactableTests.cs              | 36 +++++++++
 .../OneWay/PushReactableTests.cs              | 10 +--
 .../OneWay/RespondSubscriptionTests.cs        |  2 +-
 .../ReactableExtensionMethodsTests.cs         | 39 ++++++++++
 .../CarbonateTests/SubscriptionBaseTests.cs   | 29 ++++++++
 .../TwoWay/PushPullReactableTests.cs          | 40 +++++++++-
 .../TwoWay/ReceiveRespondSubscriptionTests.cs | 16 +++-
 61 files changed, 806 insertions(+), 580 deletions(-)
 create mode 100644 Testing/CarbonatePerfTests/Benchmarks/NonDir_PushReactable_Class.cs
 create mode 100644 Testing/CarbonatePerfTests/Benchmarks/OneWay_PullReactable_Class.cs
 create mode 100644 Testing/CarbonatePerfTests/Benchmarks/OneWay_PushReactable_Class.cs
 delete mode 100644 Testing/CarbonatePerfTests/Benchmarks/PullReactable_Class.cs
 create mode 100644 Testing/CarbonatePerfTests/Benchmarks/TwoWay_PushPullReactable_Class.cs
 delete mode 100644 Testing/CarbonatePerfTests/DataItemResult.cs
 delete mode 100644 Testing/CarbonatePerfTests/DataResult.cs
 delete mode 100644 Testing/CarbonatePerfTests/Ids.cs
 delete mode 100644 Testing/CarbonatePerfTests/MemPerfs/MemPerfRunner.cs
 delete mode 100644 Testing/CarbonatePerfTests/MemPerfs/PerfScenarios.cs
 create mode 100644 Testing/CarbonatePerfTests/PrefResults/NonDirPushreactable.md
 create mode 100644 Testing/CarbonatePerfTests/PrefResults/OneWayPullReactable.md
 create mode 100644 Testing/CarbonatePerfTests/PrefResults/OneWayPushReactable.md
 create mode 100644 Testing/CarbonatePerfTests/PrefResults/TwoWayPushPullReactable.md
 delete mode 100644 Testing/CarbonatePerfTests/PtrDataPuller.cs
 delete mode 100644 Testing/CarbonatePerfTests/PtrDataStore.cs
 delete mode 100644 Testing/CarbonatePerfTests/StructDataPuller.cs
 delete mode 100644 Testing/CarbonatePerfTests/StructDataStore.cs

diff --git a/.editorconfig b/.editorconfig
index 4d84934..fb8a5f9 100644
--- a/.editorconfig
+++ b/.editorconfig
@@ -153,6 +153,7 @@ csharp_space_around_binary_operators = before_and_after
 csharp_space_between_method_declaration_empty_parameter_list_parentheses = false
 csharp_space_between_method_call_name_and_opening_parenthesis = false
 csharp_space_between_method_call_empty_parameter_list_parentheses = false
+dotnet_diagnostic.SA1010.severity = none
 
 # Wrapping preferences
 csharp_preserve_single_line_blocks = true
diff --git a/.github/workflows/sync-bot.yml b/.github/workflows/sync-bot.yml
index d2e000f..540ec6c 100644
--- a/.github/workflows/sync-bot.yml
+++ b/.github/workflows/sync-bot.yml
@@ -44,7 +44,7 @@ jobs:
             5. PAT
           #>
           deno run `
-            --allow-net `
+            --allow-net -allow-read `
             "$scriptUrl" `
             "${{ vars.ORGANIZATION_NAME }}" `
             "${{ vars.PROJECT_NAME }}" `
diff --git a/.run/CarbonatePerfTests.run.xml b/.run/CarbonatePerfTests.run.xml
index 846f939..9f3c4a4 100644
--- a/.run/CarbonatePerfTests.run.xml
+++ b/.run/CarbonatePerfTests.run.xml
@@ -1,8 +1,8 @@
 <component name="ProjectRunConfigurationManager">
   <configuration default="false" name="CarbonatePerfTests" type="DotNetProject" factoryName=".NET Project">
-    <option name="EXE_PATH" value="$PROJECT_DIR$/Testing/CarbonatePerfTests/bin/x64/Debug/net7.0/CarbonatePerfTests.exe" />
+    <option name="EXE_PATH" value="$PROJECT_DIR$/Testing/CarbonatePerfTests/bin/x64/Debug/net8.0/CarbonatePerfTests.exe" />
     <option name="PROGRAM_PARAMETERS" value="" />
-    <option name="WORKING_DIRECTORY" value="$PROJECT_DIR$/Testing/CarbonatePerfTests/bin/x64/Debug/net7.0" />
+    <option name="WORKING_DIRECTORY" value="$PROJECT_DIR$/Testing/CarbonatePerfTests/bin/x64/Debug/net8.0" />
     <option name="PASS_PARENT_ENVS" value="1" />
     <option name="USE_EXTERNAL_CONSOLE" value="1" />
     <option name="USE_MONO" value="0" />
@@ -12,7 +12,7 @@
     <option name="PROJECT_ARGUMENTS_TRACKING" value="1" />
     <option name="PROJECT_WORKING_DIRECTORY_TRACKING" value="1" />
     <option name="PROJECT_KIND" value="DotNetCore" />
-    <option name="PROJECT_TFM" value="net7.0" />
+    <option name="PROJECT_TFM" value="net8.0" />
     <method v="2">
       <option name="Build" />
     </method>
diff --git a/.run/Samples.run.xml b/.run/Samples.run.xml
index da07112..869caac 100644
--- a/.run/Samples.run.xml
+++ b/.run/Samples.run.xml
@@ -1,8 +1,8 @@
-<component name="ProjectRunConfigurationManager">
+<component name="ProjectRunConfigurationManager">
   <configuration default="false" name="Samples" type="DotNetProject" factoryName=".NET Project">
-    <option name="EXE_PATH" value="$PROJECT_DIR$/Samples/Samples/bin/Debug/net7.0/Samples.exe" />
+    <option name="EXE_PATH" value="$PROJECT_DIR$/Samples/Samples/bin/Debug/net8.0/Samples.exe" />
     <option name="PROGRAM_PARAMETERS" value="" />
-    <option name="WORKING_DIRECTORY" value="$PROJECT_DIR$/Samples/Samples/bin/Debug/net7.0" />
+    <option name="WORKING_DIRECTORY" value="$PROJECT_DIR$/Samples/Samples/bin/Debug/net8.0" />
     <option name="PASS_PARENT_ENVS" value="1" />
     <option name="USE_EXTERNAL_CONSOLE" value="1" />
     <option name="USE_MONO" value="0" />
@@ -12,7 +12,7 @@
     <option name="PROJECT_ARGUMENTS_TRACKING" value="1" />
     <option name="PROJECT_WORKING_DIRECTORY_TRACKING" value="1" />
     <option name="PROJECT_KIND" value="DotNetCore" />
-    <option name="PROJECT_TFM" value="net7.0" />
+    <option name="PROJECT_TFM" value="net8.0" />
     <method v="2">
       <option name="Build" />
     </method>
diff --git a/.vscode/settings.json b/.vscode/settings.json
index 76efbb6..c40987e 100644
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@@ -8,6 +8,7 @@
 		"pwsh",
 		"Reactable",
 		"runsettings",
+		"struct",
 		"unsubscriber",
 		"unsubscriptions",
 		"Velaptor"
diff --git a/Carbonate.sln b/Carbonate.sln
index 97e1d68..d74e59f 100644
--- a/Carbonate.sln
+++ b/Carbonate.sln
@@ -51,51 +51,73 @@ EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|x64 = Debug|x64
-		Release Benchmark|x64 = Release Benchmark|x64
-		Release MemPerf|x64 = Release MemPerf|x64
 		Release|x64 = Release|x64
+		Release OneWayPushReactable|x64 = Release OneWayPushReactable|x64
+		Release OneWayPullReactable|x64 = Release OneWayPullReactable|x64
+		Release NonDirPushReactable|x64 = Release NonDirPushReactable|x64
+		Release TwoWayPushPullReactable|x64 = Release TwoWayPushPullReactable|x64
 	EndGlobalSection
 	GlobalSection(ProjectConfigurationPlatforms) = postSolution
 		{7858F8F1-497A-4261-94D7-339442B09494}.Debug|x64.ActiveCfg = Debug|x64
 		{7858F8F1-497A-4261-94D7-339442B09494}.Debug|x64.Build.0 = Debug|x64
-		{7858F8F1-497A-4261-94D7-339442B09494}.Release Benchmark|x64.ActiveCfg = Release|x64
-		{7858F8F1-497A-4261-94D7-339442B09494}.Release Benchmark|x64.Build.0 = Release|x64
-		{7858F8F1-497A-4261-94D7-339442B09494}.Release MemPerf|x64.ActiveCfg = Release|x64
-		{7858F8F1-497A-4261-94D7-339442B09494}.Release MemPerf|x64.Build.0 = Release|x64
 		{7858F8F1-497A-4261-94D7-339442B09494}.Release|x64.ActiveCfg = Release|x64
 		{7858F8F1-497A-4261-94D7-339442B09494}.Release|x64.Build.0 = Release|x64
+		{7858F8F1-497A-4261-94D7-339442B09494}.Release OneWayPushReactable|x64.ActiveCfg = Release|x64
+		{7858F8F1-497A-4261-94D7-339442B09494}.Release OneWayPushReactable|x64.Build.0 = Release|x64
+		{7858F8F1-497A-4261-94D7-339442B09494}.Release OneWayPullReactable|x64.ActiveCfg = Release|x64
+		{7858F8F1-497A-4261-94D7-339442B09494}.Release OneWayPullReactable|x64.Build.0 = Release|x64
+		{7858F8F1-497A-4261-94D7-339442B09494}.Release NonDirPushReactable|x64.ActiveCfg = Release|x64
+		{7858F8F1-497A-4261-94D7-339442B09494}.Release NonDirPushReactable|x64.Build.0 = Release|x64
+		{7858F8F1-497A-4261-94D7-339442B09494}.Release TwoWayPushPullReactable|x64.ActiveCfg = Release|x64
+		{7858F8F1-497A-4261-94D7-339442B09494}.Release TwoWayPushPullReactable|x64.Build.0 = Release|x64
 		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Debug|x64.ActiveCfg = Debug|x64
 		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Debug|x64.Build.0 = Debug|x64
-		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release Benchmark|x64.ActiveCfg = Release|x64
-		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release Benchmark|x64.Build.0 = Release|x64
-		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release MemPerf|x64.ActiveCfg = Release|x64
-		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release MemPerf|x64.Build.0 = Release|x64
 		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release|x64.ActiveCfg = Release|x64
 		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release|x64.Build.0 = Release|x64
+		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release OneWayPushReactable|x64.ActiveCfg = Release|x64
+		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release OneWayPushReactable|x64.Build.0 = Release|x64
+		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release OneWayPullReactable|x64.ActiveCfg = Release|x64
+		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release OneWayPullReactable|x64.Build.0 = Release|x64
+		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release NonDirPushReactable|x64.ActiveCfg = Release|x64
+		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release NonDirPushReactable|x64.Build.0 = Release|x64
+		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release TwoWayPushPullReactable|x64.ActiveCfg = Release|x64
+		{A2124FFE-C6A1-46A7-8440-F0F5709DD08C}.Release TwoWayPushPullReactable|x64.Build.0 = Release|x64
 		{388E7191-CE3A-492C-9A19-AE67A659E466}.Debug|x64.ActiveCfg = Debug|x64
 		{388E7191-CE3A-492C-9A19-AE67A659E466}.Debug|x64.Build.0 = Debug|x64
-		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release Benchmark|x64.ActiveCfg = Release|x64
-		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release Benchmark|x64.Build.0 = Release|x64
-		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release MemPerf|x64.ActiveCfg = Release|x64
-		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release MemPerf|x64.Build.0 = Release|x64
 		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release|x64.ActiveCfg = Release|x64
 		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release|x64.Build.0 = Release|x64
+		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release OneWayPushReactable|x64.ActiveCfg = Release|x64
+		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release OneWayPushReactable|x64.Build.0 = Release|x64
+		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release OneWayPullReactable|x64.ActiveCfg = Release|x64
+		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release OneWayPullReactable|x64.Build.0 = Release|x64
+		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release NonDirPushReactable|x64.ActiveCfg = Release|x64
+		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release NonDirPushReactable|x64.Build.0 = Release|x64
+		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release TwoWayPushPullReactable|x64.ActiveCfg = Release|x64
+		{388E7191-CE3A-492C-9A19-AE67A659E466}.Release TwoWayPushPullReactable|x64.Build.0 = Release|x64
 		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Debug|x64.ActiveCfg = Debug|x64
 		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Debug|x64.Build.0 = Debug|x64
-		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release Benchmark|x64.ActiveCfg = Release Benchmark|x64
-		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release Benchmark|x64.Build.0 = Release Benchmark|x64
-		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release MemPerf|x64.ActiveCfg = Release MemPerf|x64
-		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release MemPerf|x64.Build.0 = Release MemPerf|x64
 		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release|x64.ActiveCfg = Release|x64
 		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release|x64.Build.0 = Release|x64
-		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Debug|x64.ActiveCfg = Debug|Any CPU
-		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Debug|x64.Build.0 = Debug|Any CPU
-		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release Benchmark|x64.ActiveCfg = Debug|Any CPU
-		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release Benchmark|x64.Build.0 = Debug|Any CPU
-		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release MemPerf|x64.ActiveCfg = Debug|Any CPU
-		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release MemPerf|x64.Build.0 = Debug|Any CPU
-		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release|x64.ActiveCfg = Release|Any CPU
-		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release|x64.Build.0 = Release|Any CPU
+		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release OneWayPushReactable|x64.ActiveCfg = Release OneWayPushReactable|x64
+		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release OneWayPushReactable|x64.Build.0 = Release OneWayPushReactable|x64
+		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release OneWayPullReactable|x64.ActiveCfg = Release OneWayPullReactable|x64
+		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release OneWayPullReactable|x64.Build.0 = Release OneWayPullReactable|x64
+		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release NonDirPushReactable|x64.ActiveCfg = Release NonDirPushReactable|x64
+		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release NonDirPushReactable|x64.Build.0 = Release NonDirPushReactable|x64
+		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release TwoWayPushPullReactable|x64.ActiveCfg = Release TwoWayPushPullReactable|x64
+		{FA8B11A4-48C9-4824-A90F-9D39F3678028}.Release TwoWayPushPullReactable|x64.Build.0 = Release TwoWayPushPullReactable|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release|x64.ActiveCfg = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release|x64.Build.0 = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release OneWayPushReactable|x64.ActiveCfg = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release OneWayPushReactable|x64.Build.0 = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release OneWayPullReactable|x64.ActiveCfg = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release OneWayPullReactable|x64.Build.0 = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Debug|x64.ActiveCfg = Debug|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Debug|x64.Build.0 = Debug|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release NonDirPushReactable|x64.ActiveCfg = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release NonDirPushReactable|x64.Build.0 = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release TwoWayPushPullReactable|x64.ActiveCfg = Release|x64
+		{28237DD8-C8DD-41B0-864C-4C73B37DC389}.Release TwoWayPushPullReactable|x64.Build.0 = Release|x64
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
diff --git a/Carbonate.sln.DotSettings b/Carbonate.sln.DotSettings
index 372d153..df8e2e4 100644
--- a/Carbonate.sln.DotSettings
+++ b/Carbonate.sln.DotSettings
@@ -4,6 +4,7 @@
 	<s:Int64 x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/WRAP_LIMIT/@EntryValue">145</s:Int64>
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/PredefinedNamingRules/=PrivateInstanceFields/@EntryIndexedValue">&lt;Policy Inspect="True" Prefix="" Suffix="" Style="aaBb" /&gt;</s:String>
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/PredefinedNamingRules/=PrivateStaticFields/@EntryIndexedValue">&lt;Policy Inspect="True" Prefix="" Suffix="" Style="aaBb" /&gt;</s:String>
+	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=Samples_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=_002AIntegrationTests_003B_002A_003B_002A_003B_002A/@EntryIndexedValue">True</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=_002ATesting_002A_003B_002A_003B_002ATests_002A_003B_002A/@EntryIndexedValue">False</s:Boolean>
 	<s:Boolean x:Key="/Default/Environment/Filtering/ExcludeCoverageFilters/=_002ATesting_003B_002A_003B_002ATests_003B_002A/@EntryIndexedValue">False</s:Boolean>
diff --git a/Carbonate/Carbonate.csproj b/Carbonate/Carbonate.csproj
index a7c6ce4..cafffc1 100644
--- a/Carbonate/Carbonate.csproj
+++ b/Carbonate/Carbonate.csproj
@@ -38,7 +38,7 @@
 
         <!-- Ignore warning CS7035 about version syntax. -->
         <NoWarn>CS7035</NoWarn>
-        <Configurations>Debug;Release</Configurations>
+        <Configurations>Debug;Release;Release OneWayPullReactable;Release OneWayPushReactable;Release NonDirPushReactable;Release TwoWayPushPullReactable</Configurations>
     </PropertyGroup>
 
     <PropertyGroup>
diff --git a/Carbonate/Core/IReactable.cs b/Carbonate/Core/IReactable.cs
index 3409cc8..31b9975 100644
--- a/Carbonate/Core/IReactable.cs
+++ b/Carbonate/Core/IReactable.cs
@@ -4,6 +4,7 @@
 
 namespace Carbonate.Core;
 
+using System.Collections.Immutable;
 using System.Collections.ObjectModel;
 
 /// <summary>
@@ -16,7 +17,7 @@ public interface IReactable<TSubscription> : IDisposable
     /// <summary>
     /// Gets the list of subscriptions that are subscribed to this <see cref="IReactable{T}"/>.
     /// </summary>
-    ReadOnlyCollection<TSubscription> Subscriptions { get; }
+    ImmutableArray<TSubscription> Subscriptions { get; }
 
     /// <summary>
     /// Gets the list of subscription IDs.
diff --git a/Carbonate/Core/SubscriptionUnsubscriber.cs b/Carbonate/Core/SubscriptionUnsubscriber.cs
index 191d1e1..46b6052 100644
--- a/Carbonate/Core/SubscriptionUnsubscriber.cs
+++ b/Carbonate/Core/SubscriptionUnsubscriber.cs
@@ -45,10 +45,7 @@ private void Dispose(bool disposing)
 
         if (disposing)
         {
-            if (this.subscriptions.Contains(this.subscription))
-            {
-                this.subscriptions.Remove(this.subscription);
-            }
+            this.subscriptions.Remove(this.subscription);
         }
 
         this.isDisposed = true;
diff --git a/Carbonate/Fluent/SubscriptionBuilder.cs b/Carbonate/Fluent/SubscriptionBuilder.cs
index d946fe4..f8e7346 100644
--- a/Carbonate/Fluent/SubscriptionBuilder.cs
+++ b/Carbonate/Fluent/SubscriptionBuilder.cs
@@ -54,7 +54,8 @@ public ISubscriptionBuilder WithId(Guid newId)
     public ISubscriptionBuilder WithName(string name)
     {
         ArgumentException.ThrowIfNullOrEmpty(name);
-        this.subName ??= name;
+
+        this.subName = name;
         return this;
     }
 
@@ -62,7 +63,8 @@ public ISubscriptionBuilder WithName(string name)
     public ISubscriptionBuilder WhenUnsubscribing(Action onUnsubscribe)
     {
         ArgumentNullException.ThrowIfNull(onUnsubscribe);
-        this.unsubscribe ??= onUnsubscribe;
+
+        this.unsubscribe = onUnsubscribe;
         return this;
     }
 
@@ -71,7 +73,7 @@ public ISubscriptionBuilder WithError(Action<Exception> onError)
     {
         ArgumentNullException.ThrowIfNull(onError);
 
-        this.subOnError ??= onError;
+        this.subOnError = onError;
         return this;
     }
 
diff --git a/Carbonate/NonDirectional/IPushable.cs b/Carbonate/NonDirectional/IPushable.cs
index 5ef1af3..bb80c46 100644
--- a/Carbonate/NonDirectional/IPushable.cs
+++ b/Carbonate/NonDirectional/IPushable.cs
@@ -12,9 +12,9 @@ namespace Carbonate.NonDirectional;
 public interface IPushable
 {
     /// <summary>
-    /// Pushes a single notification for an event that matches the given <paramref name="eventId"/>.
+    /// Pushes a single notification for an event that matches the given <paramref name="id"/>.
     /// </summary>
-    /// <param name="eventId">The ID of the event where the notification will be pushed.</param>
+    /// <param name="id">The ID of the event where the notification will be pushed.</param>
     [SuppressMessage("ReSharper", "UnusedMemberInSuper.Global", Justification = "Public API.")]
-    void Push(Guid eventId);
+    void Push(Guid id);
 }
diff --git a/Carbonate/NonDirectional/PushReactable.cs b/Carbonate/NonDirectional/PushReactable.cs
index d51bc44..bf32017 100644
--- a/Carbonate/NonDirectional/PushReactable.cs
+++ b/Carbonate/NonDirectional/PushReactable.cs
@@ -4,13 +4,14 @@
 
 namespace Carbonate.NonDirectional;
 
+using System.Runtime.InteropServices;
 using Core.NonDirectional;
 
 /// <inheritdoc cref="IPushReactable"/>
 public class PushReactable : ReactableBase<IReceiveSubscription>, IPushReactable
 {
     /// <inheritdoc cref="IPushable.Push"/>
-    public void Push(Guid eventId)
+    public void Push(Guid id)
     {
         if (IsDisposed)
         {
@@ -19,69 +20,19 @@ public void Push(Guid eventId)
 
         try
         {
-            /* Work from the end to the beginning of the list
-             * just in case the reactable is disposed(removed)
-             * in the OnReceive() method.
-             */
-            for (var i = Subscriptions.Count - 1; i >= 0; i--)
+            foreach (var subscription in CollectionsMarshal.AsSpan(InternalSubscriptions))
             {
-                /*NOTE:
-                 * The purpose of this logic is to prevent array index errors
-                 * if an OnReceive() implementation ends up unsubscribing a single
-                 * subscription or unsubscribing from a single event id
-                 *
-                 * If the current index is not less than or equal to
-                 * the total number of items, reset the index to the last item
-                 */
-                i = i > Subscriptions.Count - 1
-                    ? Subscriptions.Count - 1
-                    : i;
-
-                if (Subscriptions[i].Id != eventId)
+                if (subscription.Id != id)
                 {
                     continue;
                 }
 
-                Subscriptions[i].OnReceive();
+                subscription.OnReceive();
             }
         }
         catch (Exception e)
         {
-            SendError(e, eventId);
-        }
-    }
-
-    /// <summary>
-    /// Sends an error to all of the subscribers that match the given <paramref name="eventId"/>.
-    /// </summary>
-    /// <param name="exception">The exception that occurred.</param>
-    /// <param name="eventId">The ID of the event where the notification will be pushed.</param>
-    private void SendError(Exception exception, Guid eventId)
-    {
-        /* Work from the end to the beginning of the list
-         * just in case the reactable is disposed(removed)
-         * in the OnReceive() method.
-         */
-        for (var i = Subscriptions.Count - 1; i >= 0; i--)
-        {
-            /*NOTE:
-             * The purpose of this logic is to prevent array index errors
-             * if an OnReceive() implementation ends up unsubscribing a single
-             * subscription or unsubscribing from a single event id
-             *
-             * If the current index is not less than or equal to
-             * the total number of items, reset the index to the last item
-             */
-            i = i > Subscriptions.Count - 1
-                ? Subscriptions.Count - 1
-                : i;
-
-            if (Subscriptions[i].Id != eventId)
-            {
-                continue;
-            }
-
-            Subscriptions[i].OnError(exception);
+            SendError(e, id);
         }
     }
 }
diff --git a/Carbonate/OneWay/IPullable.cs b/Carbonate/OneWay/IPullable.cs
index 5934b1c..cc1d463 100644
--- a/Carbonate/OneWay/IPullable.cs
+++ b/Carbonate/OneWay/IPullable.cs
@@ -11,9 +11,9 @@ namespace Carbonate.OneWay;
 public interface IPullable<out TOut>
 {
     /// <summary>
-    /// Requests to pull data from a source that matches the given <paramref name="respondId"/>.
+    /// Requests to pull data from a source that matches the given <paramref name="id"/>.
     /// </summary>
-    /// <param name="respondId">The ID of the response.</param>
+    /// <param name="id">The ID of the response.</param>
     /// <returns>The data result going out.</returns>>
-    TOut? Pull(Guid respondId);
+    TOut? Pull(Guid id);
 }
diff --git a/Carbonate/OneWay/IPushable.cs b/Carbonate/OneWay/IPushable.cs
index f038495..f8d2aae 100644
--- a/Carbonate/OneWay/IPushable.cs
+++ b/Carbonate/OneWay/IPushable.cs
@@ -13,10 +13,10 @@ namespace Carbonate.OneWay;
 public interface IPushable<TIn>
 {
     /// <summary>
-    /// Pushes a single notification with the given <paramref name="data"/> for an event that matches the given <paramref name="eventId"/>.
+    /// Pushes a single notification with the given <paramref name="data"/> for an event that matches the given <paramref name="id"/>.
     /// </summary>
+    /// <param name="id">The ID of the event where the notification will be pushed.</param>
     /// <param name="data">The data that contains the data to push.</param>
-    /// <param name="eventId">The ID of the event where the notification will be pushed.</param>
     [SuppressMessage("ReSharper", "UnusedMemberInSuper.Global", Justification = "Public API.")]
-    void Push(in TIn data, Guid eventId);
+    void Push(Guid id, in TIn data);
 }
diff --git a/Carbonate/OneWay/PullReactable.cs b/Carbonate/OneWay/PullReactable.cs
index 7c581f7..9e72c91 100644
--- a/Carbonate/OneWay/PullReactable.cs
+++ b/Carbonate/OneWay/PullReactable.cs
@@ -2,11 +2,9 @@
 // Copyright (c) KinsonDigital. All rights reserved.
 // </copyright>
 
-// NOTE: Leave the loops as 'for loops'. This is a small performance improvement.
-// ReSharper disable ForCanBeConvertedToForeach
-// ReSharper disable LoopCanBeConvertedToQuery
 namespace Carbonate.OneWay;
 
+using System.Runtime.InteropServices;
 using Core.OneWay;
 
 /// <inheritdoc cref="IPullReactable{TOut}"/>
@@ -14,16 +12,28 @@ public class PullReactable<TOut>
     : ReactableBase<IRespondSubscription<TOut>>, IPullReactable<TOut>
 {
     /// <inheritdoc/>
-    public TOut? Pull(Guid respondId)
+    public TOut? Pull(Guid id)
     {
-        for (var i = 0; i < Subscriptions.Count; i++)
+        if (IsDisposed)
         {
-            if (Subscriptions[i].Id != respondId)
+            throw new ObjectDisposedException(nameof(PullReactable<TOut>), $"{nameof(PullReactable<TOut>)} disposed.");
+        }
+
+        try
+        {
+            foreach (var subscription in CollectionsMarshal.AsSpan(InternalSubscriptions))
             {
-                continue;
-            }
+                if (subscription.Id != id)
+                {
+                    continue;
+                }
 
-            return Subscriptions[i].OnRespond() ?? default(TOut);
+                return subscription.OnRespond() ?? default(TOut);
+            }
+        }
+        catch (Exception e)
+        {
+            SendError(e, id);
         }
 
         return default;
diff --git a/Carbonate/OneWay/PushReactable.cs b/Carbonate/OneWay/PushReactable.cs
index 1acdc58..18cc3fa 100644
--- a/Carbonate/OneWay/PushReactable.cs
+++ b/Carbonate/OneWay/PushReactable.cs
@@ -4,6 +4,7 @@
 
 namespace Carbonate.OneWay;
 
+using System.Runtime.InteropServices;
 using Core.OneWay;
 
 /// <inheritdoc cref="IPushReactable{T}"/>
@@ -12,7 +13,7 @@ public class PushReactable<TIn>
 {
     /// <inheritdoc/>
     /// <exception cref="ObjectDisposedException">Thrown if this method is invoked after disposal.</exception>
-    public void Push(in TIn data, Guid eventId)
+    public void Push(Guid id, in TIn data)
     {
         if (data is null)
         {
@@ -26,69 +27,19 @@ public void Push(in TIn data, Guid eventId)
 
         try
         {
-            /* Work from the end to the beginning of the list
-             * just in case the reactable is disposed(removed)
-             * in the OnReceive() method.
-             */
-            for (var i = Subscriptions.Count - 1; i >= 0; i--)
+            foreach (var subscription in CollectionsMarshal.AsSpan(InternalSubscriptions))
             {
-                /*NOTE:
-                 * The purpose of this logic is to prevent array index errors
-                 * if an OnReceive() implementation ends up unsubscribing a single
-                 * subscription or unsubscribing from a single event id
-                 *
-                 * If the current index is not less than or equal to
-                 * the total number of items, reset the index to the last item
-                 */
-                i = i > Subscriptions.Count - 1
-                    ? Subscriptions.Count - 1
-                    : i;
-
-                if (Subscriptions[i].Id != eventId)
+                if (subscription.Id != id)
                 {
                     continue;
                 }
 
-                Subscriptions[i].OnReceive(data);
+                subscription.OnReceive(data);
             }
         }
         catch (Exception e)
         {
-            SendError(e, eventId);
-        }
-    }
-
-    /// <summary>
-    /// Sends an error to all of the subscribers that match the given <paramref name="eventId"/>.
-    /// </summary>
-    /// <param name="exception">The exception that occurred.</param>
-    /// <param name="eventId">The ID of the event where the notification will be pushed.</param>
-    private void SendError(Exception exception, Guid eventId)
-    {
-        /* Work from the end to the beginning of the list
-         * just in case the reactable is disposed(removed)
-         * in the OnReceive() method.
-         */
-        for (var i = Subscriptions.Count - 1; i >= 0; i--)
-        {
-            /*NOTE:
-             * The purpose of this logic is to prevent array index errors
-             * if an OnReceive() implementation ends up unsubscribing a single
-             * subscription or unsubscribing from a single event id
-             *
-             * If the current index is not less than or equal to
-             * the total number of items, reset the index to the last item
-             */
-            i = i > Subscriptions.Count - 1
-                ? Subscriptions.Count - 1
-                : i;
-
-            if (Subscriptions[i].Id != eventId)
-            {
-                continue;
-            }
-
-            Subscriptions[i].OnError(exception);
+            SendError(e, id);
         }
     }
 }
diff --git a/Carbonate/ReactableBase.cs b/Carbonate/ReactableBase.cs
index 83334a5..df41449 100644
--- a/Carbonate/ReactableBase.cs
+++ b/Carbonate/ReactableBase.cs
@@ -4,8 +4,10 @@
 
 namespace Carbonate;
 
+using System.Collections.Immutable;
 using System.Collections.ObjectModel;
 using System.Diagnostics.CodeAnalysis;
+using System.Runtime.InteropServices;
 using Core;
 using OneWay;
 
@@ -16,18 +18,22 @@ namespace Carbonate;
 public abstract class ReactableBase<TSubscription> : IReactable<TSubscription>
     where TSubscription : class, ISubscription
 {
-    private readonly List<TSubscription> subscriptions = new ();
     private bool notificationsEnded;
 
     /// <inheritdoc/>
-    public ReadOnlyCollection<TSubscription> Subscriptions => this.subscriptions.AsReadOnly();
+    public ImmutableArray<TSubscription> Subscriptions => InternalSubscriptions.ToImmutableArray();
 
     /// <inheritdoc/>
-    public ReadOnlyCollection<Guid> SubscriptionIds => this.subscriptions
+    public ReadOnlyCollection<Guid> SubscriptionIds => InternalSubscriptions
         .Select(r => r.Id)
         .Distinct()
         .ToList().AsReadOnly();
 
+    /// <summary>
+    /// Gets the list of subscriptions that are subscribed.
+    /// </summary>
+    internal List<TSubscription> InternalSubscriptions { get; } = [];
+
     /// <summary>
     /// Gets a value indicating whether or not if the <see cref="ReactableBase{T}"/> has been disposed.
     /// </summary>
@@ -48,9 +54,9 @@ public virtual IDisposable Subscribe(TSubscription subscription)
             throw new ArgumentNullException(nameof(subscription), "The parameter must not be null.");
         }
 
-        this.subscriptions.Add(subscription);
+        InternalSubscriptions.Add(subscription);
 
-        return new SubscriptionUnsubscriber(this.subscriptions.Cast<ISubscription>().ToList(), subscription);
+        return new SubscriptionUnsubscriber(InternalSubscriptions.Cast<ISubscription>().ToList(), subscription);
     }
 
     /// <inheritdoc/>
@@ -71,7 +77,7 @@ public virtual void Unsubscribe(Guid id)
          * This is due to the Dispose() method possibly being called during
          * iteration of the subscriptions list which will cause an exception.
         */
-        for (var i = this.subscriptions.Count - 1; i >= 0; i--)
+        for (var i = InternalSubscriptions.Count - 1; i >= 0; i--)
         {
             /*NOTE:
              * The purpose of this logic is to prevent array index errors
@@ -81,30 +87,30 @@ public virtual void Unsubscribe(Guid id)
              * If the current index is not less than or equal to
              * the total number of items, reset the index to the last item
              */
-            i = i > this.subscriptions.Count - 1
-                ? this.subscriptions.Count - 1
+            i = i > InternalSubscriptions.Count - 1
+                ? InternalSubscriptions.Count - 1
                 : i;
 
-            if (this.subscriptions[i].Id != id)
+            if (InternalSubscriptions[i].Id != id)
             {
                 continue;
             }
 
-            var beforeTotal = this.subscriptions.Count;
+            var beforeTotal = InternalSubscriptions.Count;
 
-            this.subscriptions[i].OnUnsubscribe();
+            InternalSubscriptions[i].OnUnsubscribe();
 
-            var nothingRemoved = Math.Abs(beforeTotal - this.subscriptions.Count) <= 0;
+            var nothingRemoved = Math.Abs(beforeTotal - InternalSubscriptions.Count) <= 0;
 
             // Make sure that the OnUnsubscribe implementation did not remove
             // the subscription before attempting to remove it
             if (nothingRemoved)
             {
-                this.subscriptions.Remove(this.subscriptions[i]);
+                InternalSubscriptions.Remove(InternalSubscriptions[i]);
             }
         }
 
-        this.notificationsEnded = this.subscriptions.All(r => r.Unsubscribed);
+        this.notificationsEnded = InternalSubscriptions.TrueForAll(r => r.Unsubscribed);
     }
 
     /// <inheritdoc/>
@@ -116,28 +122,12 @@ public virtual void UnsubscribeAll()
             throw new ObjectDisposedException(nameof(PushReactable<TSubscription>), $"{nameof(PushReactable<TSubscription>)} disposed.");
         }
 
-        /* Keep this loop as a for-loop.  Do not convert to for-each.
-         * This is due to the Dispose() method possibly being called during
-         * iteration of the subscriptions list which will cause an exception.
-        */
-        for (var i = this.subscriptions.Count - 1; i >= 0; i--)
+        foreach (TSubscription subscription in CollectionsMarshal.AsSpan(InternalSubscriptions))
         {
-            /*NOTE:
-             * The purpose of this logic is to prevent array index errors
-             * if an OnReceive() implementation ends up unsubscribing a single
-             * subscription or unsubscribing from a single event id
-             *
-             * If the current index is not less than or equal to
-             * the total number of items, reset the index to the last item
-             */
-            i = i > this.subscriptions.Count - 1
-                ? this.subscriptions.Count - 1
-                : i;
-
-            this.subscriptions[i].OnUnsubscribe();
+            subscription.OnUnsubscribe();
         }
 
-        this.subscriptions.Clear();
+        InternalSubscriptions.Clear();
     }
 
     /// <inheritdoc cref="IDisposable.Dispose"/>
@@ -173,4 +163,22 @@ protected virtual void Dispose(bool disposing)
 
         IsDisposed = true;
     }
+
+    /// <summary>
+    /// Sends an error to all of the subscribers that match the given <paramref name="id"/>.
+    /// </summary>
+    /// <param name="exception">The exception that occurred.</param>
+    /// <param name="id">The ID of the event where the notification will be pushed.</param>
+    protected void SendError(Exception exception, Guid id)
+    {
+        foreach (TSubscription subscription in CollectionsMarshal.AsSpan(InternalSubscriptions))
+        {
+            if (subscription.Id != id)
+            {
+                continue;
+            }
+
+            subscription.OnError(exception);
+        }
+    }
 }
diff --git a/Carbonate/SubscriptionBase.cs b/Carbonate/SubscriptionBase.cs
index 2a7b366..709545a 100644
--- a/Carbonate/SubscriptionBase.cs
+++ b/Carbonate/SubscriptionBase.cs
@@ -71,7 +71,7 @@ public virtual void OnError(Exception error)
 
         if (error is null)
         {
-            throw new ArgumentNullException(nameof(error), "The parameter must not be null.");
+            throw new ArgumentNullException(nameof(error));
         }
 
         this.onError?.Invoke(error);
diff --git a/Carbonate/TwoWay/IPushablePullable.cs b/Carbonate/TwoWay/IPushablePullable.cs
index 46968cf..dd631d9 100644
--- a/Carbonate/TwoWay/IPushablePullable.cs
+++ b/Carbonate/TwoWay/IPushablePullable.cs
@@ -14,13 +14,13 @@ namespace Carbonate.TwoWay;
 public interface IPushablePullable<TIn, out TOut>
 {
     /// <summary>
-    /// Requests to pull data from a source that matches the given <paramref name="respondId"/>,
+    /// Requests to pull data from a source that matches the given <paramref name="id"/>,
     /// with the given additional <paramref name="data"/>.
     /// </summary>
+    /// <param name="id">The ID of the response.</param>
     /// <param name="data">The data to send to the responder.</param>
-    /// <param name="respondId">The ID of the response.</param>
     /// <returns>The data result going out.</returns>
     [SuppressMessage("ReSharper", "UnusedParameter.Global", Justification = "Public API.")]
     [SuppressMessage("ReSharper", "UnusedMemberInSuper.Global", Justification = "Public API.")]
-    TOut? PushPull(in TIn data, Guid respondId);
+    TOut? PushPull(Guid id, in TIn data);
 }
diff --git a/Carbonate/TwoWay/PushPullReactable.cs b/Carbonate/TwoWay/PushPullReactable.cs
index 562049f..c5f66d5 100644
--- a/Carbonate/TwoWay/PushPullReactable.cs
+++ b/Carbonate/TwoWay/PushPullReactable.cs
@@ -7,22 +7,35 @@
 // ReSharper disable LoopCanBeConvertedToQuery
 namespace Carbonate.TwoWay;
 
+using System.Runtime.InteropServices;
 using Core.TwoWay;
 
 /// <inheritdoc cref="IPushPullReactable{TIn,TOut}"/>
 public class PushPullReactable<TIn, TOut> : ReactableBase<IReceiveRespondSubscription<TIn, TOut>>, IPushPullReactable<TIn, TOut>
 {
     /// <inheritdoc/>
-    public TOut? PushPull(in TIn data, Guid respondId)
+    public TOut? PushPull(Guid id, in TIn data)
     {
-        for (var i = 0; i < Subscriptions.Count; i++)
+        if (IsDisposed)
         {
-            if (Subscriptions[i].Id != respondId)
+            throw new ObjectDisposedException(nameof(PushPullReactable<TIn, TOut>), $"{nameof(PushPullReactable<TIn, TOut>)} disposed.");
+        }
+
+        try
+        {
+            foreach (var subscription in CollectionsMarshal.AsSpan(InternalSubscriptions))
             {
-                continue;
-            }
+                if (subscription.Id != id)
+                {
+                    continue;
+                }
 
-            return Subscriptions[i].OnRespond(data);
+                return subscription.OnRespond(data) ?? default(TOut);
+            }
+        }
+        catch (Exception e)
+        {
+            SendError(e, id);
         }
 
         return default;
diff --git a/Carbonate/TwoWay/ReceiveRespondSubscription.cs b/Carbonate/TwoWay/ReceiveRespondSubscription.cs
index 75b9468..283817c 100644
--- a/Carbonate/TwoWay/ReceiveRespondSubscription.cs
+++ b/Carbonate/TwoWay/ReceiveRespondSubscription.cs
@@ -49,7 +49,7 @@ public ReceiveRespondSubscription(
 
         if (data is null)
         {
-            throw new ArgumentNullException(nameof(data), "The parameter must not be null.");
+            throw new ArgumentNullException(nameof(data));
         }
 
         return this.onReceiveRespond is null ? default : this.onReceiveRespond.Invoke(data);
diff --git a/README.md b/README.md
index d1a167b..3d75b15 100644
--- a/README.md
+++ b/README.md
@@ -171,7 +171,7 @@ var favoriteMessenger = new PushPullReactable<string, string>();
 var subId = Guid.NewGuid(); // This is the ID used to identify the event
 
 var unsubscriber = favoriteMessenger.Subscribe(new ReceiveRespondSubscription<string, string>(
-    respondId: subId,
+    id: subId,
     onRespond: (data) => data switch
         {
             "prog-lang" => "C#",
diff --git a/Samples/Samples/OneWayWithoutFluentApiSample.cs b/Samples/Samples/OneWayWithoutFluentApiSample.cs
index 5f28b53..436417d 100644
--- a/Samples/Samples/OneWayWithoutFluentApiSample.cs
+++ b/Samples/Samples/OneWayWithoutFluentApiSample.cs
@@ -39,7 +39,7 @@ public override void Run()
             onUnsubscribe: () => Console.WriteLine("Unsubscribed from notifications!"),
             onError: ex => Console.WriteLine($"Error: {ex.Message}")));
 
-        dataSender.Push("hello world!", msgEventId); // Will invoke all onReceive 'Actions'
+        dataSender.Push(msgEventId, "hello world!"); // Will invoke all onReceive 'Actions'
         unsubscriber.Dispose(); // This will only unsubscribe the single subscription created above
 
         // This will unsubscribe all subscriptions for the given event ID
diff --git a/Samples/Samples/Program.cs b/Samples/Samples/Program.cs
index 8f2dab1..95f7132 100644
--- a/Samples/Samples/Program.cs
+++ b/Samples/Samples/Program.cs
@@ -5,8 +5,10 @@
 // ReSharper disable HeapView.ObjectAllocation.Evident
 // ReSharper disable HeapView.DelegateAllocation
 // ReSharper disable HeapView.ObjectAllocation
+#pragma warning disable SA1200
 using System.Runtime.InteropServices;
 using Samples;
+#pragma warning restore SA1200
 
 // Check if the current platform is windows
 if (RuntimeInformation.IsOSPlatform(OSPlatform.Windows))
diff --git a/Samples/Samples/Samples.csproj b/Samples/Samples/Samples.csproj
index f77c136..1ba8487 100644
--- a/Samples/Samples/Samples.csproj
+++ b/Samples/Samples/Samples.csproj
@@ -6,6 +6,8 @@
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
         <DockerDefaultTargetOS>Windows</DockerDefaultTargetOS>
+        <Configurations>Debug;Release;Release OneWayPullReactable;Release OneWayPushReactable;Release NonDirPushReactable;Release TwoWayPushPullReactable</Configurations>
+        <Platforms>x64</Platforms>
     </PropertyGroup>
 
     <ItemGroup>
diff --git a/Samples/Samples/TwoWayWithoutFluentApi.cs b/Samples/Samples/TwoWayWithoutFluentApi.cs
index 56f64ec..a66696d 100644
--- a/Samples/Samples/TwoWayWithoutFluentApi.cs
+++ b/Samples/Samples/TwoWayWithoutFluentApi.cs
@@ -44,10 +44,10 @@ public override void Run()
             onError: ex => Console.WriteLine($"Error: {ex.Message}")));
 
         // Print the results of the data returned for each push notification
-        Console.WriteLine($"Favorite Language: {favoriteRequester.PushPull("prog-lang", msgEventId)}");
-        Console.WriteLine($"Favorite Food: {favoriteRequester.PushPull("food", msgEventId)}");
-        Console.WriteLine($"Favorite Past Time: {favoriteRequester.PushPull("past-time", msgEventId)}");
-        Console.WriteLine($"Favorite Music: {favoriteRequester.PushPull("music", msgEventId)}");
+        Console.WriteLine($"Favorite Language: {favoriteRequester.PushPull(msgEventId, "prog-lang")}");
+        Console.WriteLine($"Favorite Food: {favoriteRequester.PushPull(msgEventId, "food")}");
+        Console.WriteLine($"Favorite Past Time: {favoriteRequester.PushPull(msgEventId, "past-time")}");
+        Console.WriteLine($"Favorite Music: {favoriteRequester.PushPull(msgEventId, "music")}");
 
         unsubscriber.Dispose();
 
diff --git a/Testing/CarbonateIntegrationTests/CarbonateIntegrationTests.csproj b/Testing/CarbonateIntegrationTests/CarbonateIntegrationTests.csproj
index c3bb61e..17ba76b 100644
--- a/Testing/CarbonateIntegrationTests/CarbonateIntegrationTests.csproj
+++ b/Testing/CarbonateIntegrationTests/CarbonateIntegrationTests.csproj
@@ -6,7 +6,7 @@
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
         <IsPackable>false</IsPackable>
-        <Configurations>Release;Debug</Configurations>
+        <Configurations>Release;Debug;Release OneWayPullReactable;Release OneWayPushReactable;Release NonDirPushReactable;Release TwoWayPushPullReactable</Configurations>
         <Platforms>x64</Platforms>
     </PropertyGroup>
 
diff --git a/Testing/CarbonateIntegrationTests/PullReactableWithoutDataGoingIn_IntegrationTests.cs b/Testing/CarbonateIntegrationTests/PullReactableWithoutDataGoingIn_IntegrationTests.cs
index a179079..41e7956 100644
--- a/Testing/CarbonateIntegrationTests/PullReactableWithoutDataGoingIn_IntegrationTests.cs
+++ b/Testing/CarbonateIntegrationTests/PullReactableWithoutDataGoingIn_IntegrationTests.cs
@@ -95,7 +95,7 @@ public void WhenUsingPushReactable_WithData_WorksCorrectly()
 
         // Act
         var actualNames = sut.Subscriptions.Select(s => s.Name).ToArray();
-        sut.Push(testData, id);
+        sut.Push(id, testData);
         sut.Unsubscribe(id);
 
         // Assert
@@ -130,7 +130,7 @@ public void WhenUsingPushPullReactable_WithData_WorksCorrectly()
 
         // Act
         var actualNames = sut.Subscriptions.Select(s => s.Name).ToArray();
-        var actualOutData = sut.PushPull(123, id);
+        var actualOutData = sut.PushPull(id, 123);
         sut.Unsubscribe(id);
 
         // Assert
diff --git a/Testing/CarbonateIntegrationTests/PushPullReactableWithData_IntegrationTests.cs b/Testing/CarbonateIntegrationTests/PushPullReactableWithData_IntegrationTests.cs
index 025b506..82f3718 100644
--- a/Testing/CarbonateIntegrationTests/PushPullReactableWithData_IntegrationTests.cs
+++ b/Testing/CarbonateIntegrationTests/PushPullReactableWithData_IntegrationTests.cs
@@ -27,7 +27,7 @@ public void WhenUsingPushPull_WithOutgoingData_ReturnsCorrectResult()
             onReceiveRespond: _ => new SampleData { IntValue = 123, StringValue = "test-str" }));
 
         // Act
-        var actual = sut.PushPull(123, respondId);
+        var actual = sut.PushPull(respondId, 123);
 
         // Assert
         actual.Should().NotBeNull();
diff --git a/Testing/CarbonatePerfTests/Benchmarks/NonDir_PushReactable_Class.cs b/Testing/CarbonatePerfTests/Benchmarks/NonDir_PushReactable_Class.cs
new file mode 100644
index 0000000..cd15f8c
--- /dev/null
+++ b/Testing/CarbonatePerfTests/Benchmarks/NonDir_PushReactable_Class.cs
@@ -0,0 +1,40 @@
+// <copyright file="NonDir_PushReactable_Class.cs" company="KinsonDigital">
+// Copyright (c) KinsonDigital. All rights reserved.
+// </copyright>
+
+namespace CarbonatePerfTests.Benchmarks;
+
+using System.Diagnostics.CodeAnalysis;
+using BenchmarkDotNet.Attributes;
+using Carbonate.NonDirectional;
+
+[MemoryDiagnoser]
+[SuppressMessage("ReSharper", "InconsistentNaming", Justification = "Perf testing.")]
+[SuppressMessage("csharpsquid", "S101", Justification = "Perf testing")]
+public class NonDir_PushReactable_Class
+{
+    private const string NameSpace = nameof(Carbonate.NonDirectional);
+    private const string ClassName = nameof(PushReactable);
+    private const string MethodName = $"{nameof(PushReactable.Push)}()";
+    private readonly Guid setupAId = Guid.NewGuid();
+    private PushReactable? pushReactable;
+
+    [Params(10, 100, 1_000)]
+    public int TotalSubscriptions { get; set; }
+
+    [GlobalSetup]
+    public void GlobalSetup()
+    {
+        this.pushReactable = new PushReactable();
+        for (var i = 0; i < TotalSubscriptions; i++)
+        {
+            this.pushReactable.Subscribe(new ReceiveSubscription(this.setupAId, () => { }));
+        }
+    }
+
+    [Benchmark(Description = $"{NameSpace}.{ClassName}.{MethodName}")]
+    public void PushReactable_Push_Method_Setup()
+    {
+        this.pushReactable.Push(this.setupAId);
+    }
+}
diff --git a/Testing/CarbonatePerfTests/Benchmarks/OneWay_PullReactable_Class.cs b/Testing/CarbonatePerfTests/Benchmarks/OneWay_PullReactable_Class.cs
new file mode 100644
index 0000000..e479904
--- /dev/null
+++ b/Testing/CarbonatePerfTests/Benchmarks/OneWay_PullReactable_Class.cs
@@ -0,0 +1,60 @@
+// <copyright file="OneWay_PullReactable_Class.cs" company="KinsonDigital">
+// Copyright (c) KinsonDigital. All rights reserved.
+// </copyright>
+
+// ReSharper disable UnusedAutoPropertyAccessor.Global
+namespace CarbonatePerfTests.Benchmarks;
+
+using System.Diagnostics.CodeAnalysis;
+using BenchmarkDotNet.Attributes;
+using Carbonate.OneWay;
+
+[MemoryDiagnoser]
+[SuppressMessage("ReSharper", "InconsistentNaming", Justification = "Perf testing.")]
+[SuppressMessage("csharpsquid", "S101", Justification = "Perf testing")]
+public class OneWay_PullReactable_Class
+{
+    private const string NameSpace = nameof(Carbonate.OneWay);
+    private const string IntType = "int";
+    private const string StructType = nameof(StructItem);
+    private const string PullIntClassName = $"{nameof(PullReactable<int>)}<{IntType}>";
+    private const string PullStructClassName = $"{nameof(PullReactable<StructItem>)}<{StructType}>";
+    private const string MethodName = $"{nameof(IPullReactable<int>.Pull)}()";
+    private readonly Guid setupAId = Guid.NewGuid();
+    private readonly Guid setupBId = Guid.NewGuid();
+    private PullReactable<int>? pullReactableA;
+    private PullReactable<StructItem>? pullReactableB;
+    private StructItem structItem;
+
+    [Params(10, 100, 1_000)]
+    public int TotalSubscriptions { get; set; }
+
+    [GlobalSetup]
+    public void GlobalSetup()
+    {
+        this.pullReactableA = new PullReactable<int>();
+        for (var i = 0; i < TotalSubscriptions; i++)
+        {
+            this.pullReactableA.Subscribe(new RespondSubscription<int>(this.setupAId, () => 123));
+        }
+
+        this.structItem = new StructItem { NumberValue = 123 };
+        this.pullReactableB = new PullReactable<StructItem>();
+        for (var i = 0; i < TotalSubscriptions; i++)
+        {
+            this.pullReactableB.Subscribe(new RespondSubscription<StructItem>(this.setupAId, () => this.structItem));
+        }
+    }
+
+    [Benchmark(Description = $"{NameSpace}.{PullIntClassName}.{MethodName}")]
+    public void PullReactable_Pull_Method_Setup_A()
+    {
+        _ = this.pullReactableA.Pull(this.setupAId);
+    }
+
+    [Benchmark(Description = $"{NameSpace}.{PullStructClassName}.{MethodName}")]
+    public void PullReactable_Pull_Method_Setup_B()
+    {
+        _ = this.pullReactableB.Pull(this.setupBId);
+    }
+}
diff --git a/Testing/CarbonatePerfTests/Benchmarks/OneWay_PushReactable_Class.cs b/Testing/CarbonatePerfTests/Benchmarks/OneWay_PushReactable_Class.cs
new file mode 100644
index 0000000..6496a53
--- /dev/null
+++ b/Testing/CarbonatePerfTests/Benchmarks/OneWay_PushReactable_Class.cs
@@ -0,0 +1,60 @@
+// <copyright file="OneWay_PushReactable_Class.cs" company="KinsonDigital">
+// Copyright (c) KinsonDigital. All rights reserved.
+// </copyright>
+
+// ReSharper disable UnusedAutoPropertyAccessor.Global
+namespace CarbonatePerfTests.Benchmarks;
+
+using System.Diagnostics.CodeAnalysis;
+using BenchmarkDotNet.Attributes;
+using Carbonate.OneWay;
+
+[MemoryDiagnoser]
+[SuppressMessage("ReSharper", "InconsistentNaming", Justification = "Perf testing.")]
+[SuppressMessage("csharpsquid", "S101", Justification = "Perf testing")]
+public class OneWay_PushReactable_Class
+{
+    private const string NameSpace = nameof(Carbonate.OneWay);
+    private const string IntType = "int";
+    private const string StructType = nameof(StructItem);
+    private const string PushIntClassName = $"{nameof(PushReactable<int>)}<{IntType}>";
+    private const string PushStructClassName = $"{nameof(PushReactable<StructItem>)}<{StructType}>";
+    private const string MethodName = $"{nameof(IPushReactable<int>.Push)}()";
+    private readonly Guid setupAId = Guid.NewGuid();
+    private readonly Guid setupBId = Guid.NewGuid();
+    private PushReactable<int>? pushReactableA;
+    private PushReactable<StructItem>? pushReactableB;
+    private StructItem structItem;
+
+    [Params(10, 100, 1_000)]
+    public int TotalSubscriptions { get; set; }
+
+    [GlobalSetup]
+    public void GlobalSetup()
+    {
+        this.pushReactableA = new PushReactable<int>();
+        for (var i = 0; i < TotalSubscriptions; i++)
+        {
+            this.pushReactableA.Subscribe(new ReceiveSubscription<int>(this.setupAId, _ => { }));
+        }
+
+        this.structItem = new StructItem { NumberValue = 123 };
+        this.pushReactableB = new PushReactable<StructItem>();
+        for (var i = 0; i < TotalSubscriptions; i++)
+        {
+            this.pushReactableB.Subscribe(new ReceiveSubscription<StructItem>(this.setupAId, _ => { }));
+        }
+    }
+
+    [Benchmark(Description = $"{NameSpace}.{PushIntClassName}.{MethodName}")]
+    public void PushReactable_Push_Method_Setup_A()
+    {
+        this.pushReactableA.Push(this.setupAId, 123);
+    }
+
+    [Benchmark(Description = $"{NameSpace}.{PushStructClassName}.{MethodName}")]
+    public void PushReactable_Push_Method_Setup_B()
+    {
+        this.pushReactableB.Push(this.setupBId, this.structItem);
+    }
+}
diff --git a/Testing/CarbonatePerfTests/Benchmarks/PullReactable_Class.cs b/Testing/CarbonatePerfTests/Benchmarks/PullReactable_Class.cs
deleted file mode 100644
index 86a0ead..0000000
--- a/Testing/CarbonatePerfTests/Benchmarks/PullReactable_Class.cs
+++ /dev/null
@@ -1,50 +0,0 @@
-// <copyright file="PullReactable_Class.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests.Benchmarks;
-
-using System.Diagnostics.CodeAnalysis;
-using BenchmarkDotNet.Attributes;
-using BenchmarkDotNet.Order;
-using Carbonate.OneWay;
-
-[MemoryDiagnoser]
-[Orderer(SummaryOrderPolicy.FastestToSlowest)]
-[SuppressMessage("ReSharper", "InconsistentNaming", Justification = "Only used for testing.")]
-public class PullReactable_Class
-{
-    // ReSharper disable NotAccessedField.Local
-    private PullReactable<StructItem[]>? pullReactableA;
-    private PullReactable<nint>? pullReactableB;
-    private StructDataStore? structDataStore;
-    private StructDataPuller? structDataPuller;
-    private PtrDataStore? ptrDataStore;
-    private PtrDataPuller? ptrDataPuller;
-
-    // ReSharper restore NotAccessedField.Local
-    [GlobalSetup]
-    public void GlobalSetup()
-    {
-        this.pullReactableA = new PullReactable<StructItem[]>();
-        this.pullReactableB = new PullReactable<nint>();
-
-        this.structDataStore = new StructDataStore(this.pullReactableA);
-        this.structDataPuller = new StructDataPuller(this.pullReactableA);
-
-        this.ptrDataStore = new PtrDataStore(this.pullReactableB);
-        this.ptrDataPuller = new PtrDataPuller(this.pullReactableB);
-    }
-
-    [Benchmark(Description = "PullReactable.Pull() Method | Setup A")]
-    public void PullReactable_Pull_Method_Setup_A()
-    {
-        _ = this.structDataPuller.Pull();
-    }
-
-    [Benchmark(Description = "PullReactable.Pull() Method | Setup B")]
-    public void PullReactable_Pull_Method_Setup_B()
-    {
-        _ = this.ptrDataPuller.Pull();
-    }
-}
diff --git a/Testing/CarbonatePerfTests/Benchmarks/TwoWay_PushPullReactable_Class.cs b/Testing/CarbonatePerfTests/Benchmarks/TwoWay_PushPullReactable_Class.cs
new file mode 100644
index 0000000..276eeea
--- /dev/null
+++ b/Testing/CarbonatePerfTests/Benchmarks/TwoWay_PushPullReactable_Class.cs
@@ -0,0 +1,60 @@
+// <copyright file="TwoWay_PushPullReactable_Class.cs" company="KinsonDigital">
+// Copyright (c) KinsonDigital. All rights reserved.
+// </copyright>
+
+// ReSharper disable UnusedAutoPropertyAccessor.Global
+namespace CarbonatePerfTests.Benchmarks;
+
+using BenchmarkDotNet.Attributes;
+using System.Diagnostics.CodeAnalysis;
+using Carbonate.TwoWay;
+
+[MemoryDiagnoser]
+[SuppressMessage("ReSharper", "InconsistentNaming", Justification = "Perf testing.")]
+[SuppressMessage("csharpsquid", "S101", Justification = "Perf testing")]
+public class TwoWay_PushPullReactable_Class
+{
+    private const string NameSpace = nameof(Carbonate.TwoWay);
+    private const string IntType = "int";
+    private const string StructType = nameof(StructItem);
+    private const string PushIntPullIntClassName = $"{nameof(PushPullReactable<int, int>)}<{IntType}, {IntType}>";
+    private const string PushIntPullStructClassName = $"{nameof(PushPullReactable<int, StructItem>)}<{IntType}, {StructType}>";
+    private const string MethodName = $"{nameof(IPushPullReactable<int, StructItem>.PushPull)}()";
+    private readonly Guid setupAId = Guid.NewGuid();
+    private readonly Guid setupBId = Guid.NewGuid();
+    private PushPullReactable<int, int>? pushPullReactableA;
+    private PushPullReactable<int, StructItem>? pushPullReactableB;
+    private StructItem structItem;
+
+    [Params(10, 100, 1_000)]
+    public int TotalSubscriptions { get; set; }
+
+    [GlobalSetup]
+    public void GlobalSetup()
+    {
+        this.pushPullReactableA = new PushPullReactable<int, int>();
+        for (var i = 0; i < TotalSubscriptions; i++)
+        {
+            this.pushPullReactableA.Subscribe(new ReceiveRespondSubscription<int, int>(this.setupAId, _ => 123));
+        }
+
+        this.structItem = new StructItem { NumberValue = 456 };
+        this.pushPullReactableB = new PushPullReactable<int, StructItem>();
+        for (var i = 0; i < TotalSubscriptions; i++)
+        {
+            this.pushPullReactableB.Subscribe(new ReceiveRespondSubscription<int, StructItem>(this.setupAId, _ => this.structItem));
+        }
+    }
+
+    [Benchmark(Description = $"{NameSpace}.{PushIntPullIntClassName}.{MethodName}")]
+    public void PullReactable_Pull_Method_Setup_A()
+    {
+        _ = this.pushPullReactableA.PushPull(this.setupAId, 10);
+    }
+
+    [Benchmark(Description = $"{NameSpace}.{PushIntPullStructClassName}.{MethodName}")]
+    public void PullReactable_Pull_Method_Setup_B()
+    {
+        _ = this.pushPullReactableB.PushPull(this.setupBId, 20);
+    }
+}
diff --git a/Testing/CarbonatePerfTests/CarbonatePerfTests.csproj b/Testing/CarbonatePerfTests/CarbonatePerfTests.csproj
index 98d01be..bf56b30 100644
--- a/Testing/CarbonatePerfTests/CarbonatePerfTests.csproj
+++ b/Testing/CarbonatePerfTests/CarbonatePerfTests.csproj
@@ -6,16 +6,27 @@
         <LangVersion>12.0</LangVersion>
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
-        <Configurations>Release;Debug;Release Benchmark;Release MemPerf</Configurations>
+        <Configurations>Release;Debug;Release OneWayPushReactable;Release OneWayPullReactable;Release NonDirPushReactable;Release TwoWayPushPullReactable</Configurations>
         <Platforms>x64</Platforms>
         <AllowUnsafeBlocks>true</AllowUnsafeBlocks>
     </PropertyGroup>
 
-    <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release Benchmark|x64' ">
+    <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release OneWayPushReactable|x64' ">
       <Optimize>true</Optimize>
+      <OutputPath>bin\x64\OneWayPushReactable\</OutputPath>
     </PropertyGroup>
 
-    <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release MemPerf|x64' ">
+    <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release OneWayPullReactable|x64' ">
+      <Optimize>true</Optimize>
+      <OutputPath>bin\x64\OneWayPullReactable\</OutputPath>
+    </PropertyGroup>
+
+    <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release NonDirPushReactable|x64' ">
+      <OutputPath>bin\x64\NonDirPushReactable\</OutputPath>
+      <Optimize>true</Optimize>
+    </PropertyGroup>
+
+    <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release TwoWayPushPullReactable|x64' ">
       <Optimize>true</Optimize>
     </PropertyGroup>
 
diff --git a/Testing/CarbonatePerfTests/DataItemResult.cs b/Testing/CarbonatePerfTests/DataItemResult.cs
deleted file mode 100644
index 2d9be2e..0000000
--- a/Testing/CarbonatePerfTests/DataItemResult.cs
+++ /dev/null
@@ -1,16 +0,0 @@
-// <copyright file="DataItemResult.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests;
-
-public class DataItemResult
-{
-    private readonly StructItem[] dataItems;
-
-    public DataItemResult(Memory<StructItem> dataItems) => this.dataItems = dataItems.ToArray();
-
-    public bool IsEmpty => false;
-
-    public StructItem[] GetValue(Action<Exception>? onError = null) => this.dataItems;
-}
diff --git a/Testing/CarbonatePerfTests/DataResult.cs b/Testing/CarbonatePerfTests/DataResult.cs
deleted file mode 100644
index 2a78eaa..0000000
--- a/Testing/CarbonatePerfTests/DataResult.cs
+++ /dev/null
@@ -1,16 +0,0 @@
-// <copyright file="DataResult.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests;
-
-public class DataResult
-{
-    private readonly nint dataItems;
-
-    public DataResult(nint dataItems) => this.dataItems = dataItems;
-
-    public bool IsEmpty => false;
-
-    public nint GetValue(Action<Exception>? onError = null) => this.dataItems;
-}
diff --git a/Testing/CarbonatePerfTests/Ids.cs b/Testing/CarbonatePerfTests/Ids.cs
deleted file mode 100644
index 54fc316..0000000
--- a/Testing/CarbonatePerfTests/Ids.cs
+++ /dev/null
@@ -1,16 +0,0 @@
-// <copyright file="Ids.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests;
-
-/// <summary>
-/// Used for testing.
-/// </summary>
-public static class Ids
-{
-    /// <summary>
-    /// Gets a <see cref="Guid"/> used for testing.
-    /// </summary>
-    public static Guid GetDatId { get; } = new ("daa5ed5a-dd38-49a3-bec9-881af21100ec");
-}
diff --git a/Testing/CarbonatePerfTests/MemPerfs/MemPerfRunner.cs b/Testing/CarbonatePerfTests/MemPerfs/MemPerfRunner.cs
deleted file mode 100644
index c3af17c..0000000
--- a/Testing/CarbonatePerfTests/MemPerfs/MemPerfRunner.cs
+++ /dev/null
@@ -1,57 +0,0 @@
-// <copyright file="MemPerfRunner.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests.MemPerfs;
-
-using System.Diagnostics.CodeAnalysis;
-using Carbonate.OneWay;
-
-public static class MemPerfRunner
-{
-    // ReSharper disable NotAccessedField.Local
-    private static readonly StructDataStore StructStructDataStore;
-    private static readonly StructDataPuller StructStructDataPuller;
-    private static readonly PtrDataStore PointerDataStore;
-    private static readonly PtrDataPuller PointerDataPuller;
-
-    // ReSharper restore NotAccessedField.Local
-
-    /// <summary>
-    /// Initializes static members of the <see cref="MemPerfRunner"/> class.
-    /// </summary>
-    static MemPerfRunner()
-    {
-        var pullStructReactable = new PullReactable<StructItem[]>();
-        StructStructDataStore = new StructDataStore(pullStructReactable);
-        StructStructDataPuller = new StructDataPuller(pullStructReactable);
-
-        var pullPtrReactable = new PullReactable<nint>();
-        PointerDataStore = new PtrDataStore(pullPtrReactable);
-        PointerDataPuller = new PtrDataPuller(pullPtrReactable);
-    }
-
-    [SuppressMessage("ReSharper", "UnusedMember.Global", Justification = "Used for testing.")]
-    public static void Run(PerfScenarios perfScenarioTypes, int iterationTime = -1)
-    {
-        while (true)
-        {
-            switch (perfScenarioTypes)
-            {
-                case PerfScenarios.PullReactable_Pull_Method_With_Struct:
-                    _ = StructStructDataPuller.Pull();
-                    break;
-                case PerfScenarios.PullReactable_Pull_Method_With_Ptr:
-                    _ = PointerDataPuller.Pull();
-                    break;
-                default:
-                    throw new ArgumentOutOfRangeException(nameof(perfScenarioTypes), perfScenarioTypes, null);
-            }
-
-            if (iterationTime != -1)
-            {
-                Thread.Sleep(iterationTime);
-            }
-        }
-    }
-}
diff --git a/Testing/CarbonatePerfTests/MemPerfs/PerfScenarios.cs b/Testing/CarbonatePerfTests/MemPerfs/PerfScenarios.cs
deleted file mode 100644
index 86a6655..0000000
--- a/Testing/CarbonatePerfTests/MemPerfs/PerfScenarios.cs
+++ /dev/null
@@ -1,26 +0,0 @@
-// <copyright file="PerfScenarios.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-// ReSharper disable InconsistentNaming
-namespace CarbonatePerfTests.MemPerfs;
-
-using Carbonate.OneWay;
-
-/// <summary>
-/// Used for testing different scenarios.
-/// </summary>
-public enum PerfScenarios
-{
-    /// <summary>
-    /// For testing the <see cref="PullReactable{TOut}"/>.<see cref="PullReactable{TOut}.Pull(System.Guid)"/>
-    /// method for <c>struct</c> types.
-    /// </summary>
-    PullReactable_Pull_Method_With_Struct,
-
-    /// <summary>
-    /// For testing the <see cref="PullReactable{TOut}"/>.<see cref="PullReactable{TOut}.Pull(System.Guid)"/>
-    /// method for <see cref="nint"/> types.
-    /// </summary>
-    PullReactable_Pull_Method_With_Ptr,
-}
diff --git a/Testing/CarbonatePerfTests/PrefResults/NonDirPushreactable.md b/Testing/CarbonatePerfTests/PrefResults/NonDirPushreactable.md
new file mode 100644
index 0000000..bb195be
--- /dev/null
+++ b/Testing/CarbonatePerfTests/PrefResults/NonDirPushreactable.md
@@ -0,0 +1,23 @@
+BenchmarkDotNet v0.13.11, Windows 11 (10.0.22631.3007/23H2/2023Update/SunValley3)
+12th Gen Intel Core i9-12900HK, 1 CPU, 20 logical and 14 physical cores
+.NET SDK 8.0.100
+  [Host]     : .NET 8.0.0 (8.0.23.53103), X64 RyuJIT AVX2
+  DefaultJob : .NET 8.0.0 (8.0.23.53103), X64 RyuJIT AVX2
+
+**Description:** Baseline - Standard for loop
+
+| Method                              | TotalSubscriptions | Mean        | Error     | StdDev    | Allocated |
+|------------------------------------ |------------------- |------------:|----------:|----------:|----------:|
+| NonDirectional.PushReactable.Push() | 10                 |    21.11 ns |  0.432 ns |  0.577 ns |         - |
+| NonDirectional.PushReactable.Push() | 100                |   183.64 ns |  3.050 ns |  2.704 ns |         - |
+| NonDirectional.PushReactable.Push() | 1000               | 2,045.12 ns | 24.447 ns | 21.672 ns |         - |
+
+---
+
+**Description:** Upgrade To CollectionsMarshal.AsSpan()
+
+| Method                              | TotalSubscriptions | Mean        | Error     | StdDev    | Allocated |
+|------------------------------------ |------------------- |------------:|----------:|----------:|----------:|
+| NonDirectional.PushReactable.Push() | 10                 |    11.89 ns |  0.215 ns |  0.201 ns |         - |
+| NonDirectional.PushReactable.Push() | 100                |   112.36 ns |  2.237 ns |  2.747 ns |         - |
+| NonDirectional.PushReactable.Push() | 1000               | 1,123.29 ns | 16.086 ns | 15.047 ns |         - |
diff --git a/Testing/CarbonatePerfTests/PrefResults/OneWayPullReactable.md b/Testing/CarbonatePerfTests/PrefResults/OneWayPullReactable.md
new file mode 100644
index 0000000..6279ab8
--- /dev/null
+++ b/Testing/CarbonatePerfTests/PrefResults/OneWayPullReactable.md
@@ -0,0 +1,30 @@
+BenchmarkDotNet v0.13.11, Windows 11 (10.0.22631.3007/23H2/2023Update/SunValley3)
+12th Gen Intel Core i9-12900HK, 1 CPU, 20 logical and 14 physical cores
+.NET SDK 8.0.100
+[Host]     : .NET 8.0.0 (8.0.23.53103), X64 RyuJIT AVX2 [AttachedDebugger]
+DefaultJob : .NET 8.0.0 (8.0.23.53103), X64 RyuJIT AVX2
+
+
+**Description:** Baseline - Standard for loop
+
+| Method                                        | TotalSubscriptions | Mean          | Error        | StdDev        | Median        | Gen0     | Allocated |
+|---------------------------------------------- |------------------- |--------------:|-------------:|--------------:|--------------:|---------:|----------:|
+| 'OneWay.PullReactable.Pull() Method | int'    | 10                 |      48.53 ns |     1.004 ns |      2.225 ns |      47.75 ns |   0.0166 |     208 B |
+| 'OneWay.PullReactable.Pull() Method | int'    | 100                |     136.20 ns |     3.325 ns |      9.803 ns |     134.40 ns |   0.1311 |    1648 B |
+| 'OneWay.PullReactable.Pull() Method | int'    | 1000               |     913.80 ns |    33.283 ns |     98.137 ns |     918.23 ns |   1.2779 |   16048 B |
+| 'OneWay.PullReactable.Pull() Method | struct' | 10                 |     261.33 ns |     5.243 ns |     14.875 ns |     256.23 ns |   0.0827 |    1040 B |
+| 'OneWay.PullReactable.Pull() Method | struct' | 100                |   6,088.33 ns |   118.878 ns |    211.306 ns |   6,071.15 ns |   6.5613 |   82400 B |
+| 'OneWay.PullReactable.Pull() Method | struct' | 1000               | 452,384.60 ns | 9,033.799 ns | 21,469.779 ns | 442,431.15 ns | 639.1602 | 8024000 B |
+
+---
+
+**Description:** Upgrade To CollectionsMarshal.AsSpan()
+
+| Method                                        | TotalSubscriptions | Mean       | Error     | StdDev    | Allocated |
+|---------------------------------------------- |------------------- |-----------:|----------:|----------:|----------:|
+| 'OneWay.PullReactable.Pull() Method | int'    | 10                 |   3.012 ns | 0.0928 ns | 0.1032 ns |         - |
+| 'OneWay.PullReactable.Pull() Method | int'    | 100                |   2.594 ns | 0.0816 ns | 0.1271 ns |         - |
+| 'OneWay.PullReactable.Pull() Method | int'    | 1000               |   2.670 ns | 0.0767 ns | 0.0970 ns |         - |
+| 'OneWay.PullReactable.Pull() Method | struct' | 10                 |   6.637 ns | 0.1521 ns | 0.3952 ns |         - |
+| 'OneWay.PullReactable.Pull() Method | struct' | 100                |  65.871 ns | 1.3041 ns | 1.2808 ns |         - |
+| 'OneWay.PullReactable.Pull() Method | struct' | 1000               | 775.474 ns | 4.2197 ns | 3.7406 ns |         - |
diff --git a/Testing/CarbonatePerfTests/PrefResults/OneWayPushReactable.md b/Testing/CarbonatePerfTests/PrefResults/OneWayPushReactable.md
new file mode 100644
index 0000000..8521a7b
--- /dev/null
+++ b/Testing/CarbonatePerfTests/PrefResults/OneWayPushReactable.md
@@ -0,0 +1,30 @@
+BenchmarkDotNet v0.13.11, Windows 11 (10.0.22631.3007/23H2/2023Update/SunValley3)
+12th Gen Intel Core i9-12900HK, 1 CPU, 20 logical and 14 physical cores
+.NET SDK 8.0.100
+[Host]     : .NET 8.0.0 (8.0.23.53103), X64 RyuJIT AVX2 [AttachedDebugger]
+DefaultJob : .NET 8.0.0 (8.0.23.53103), X64 RyuJIT AVX2
+
+
+**Description:** Baseline - Standard for loop
+
+| Method                                        | TotalSubscriptions | Mean           | Error        | StdDev       | Median         | Gen0      | Allocated   |
+|---------------------------------------------- |------------------- |---------------:|-------------:|-------------:|---------------:|----------:|------------:|
+| 'OneWay.PushReactable.Push() Method | int'    | 10                 |       777.2 ns |     15.57 ns |     41.84 ns |       763.8 ns |    0.2480 |     3.05 KB |
+| 'OneWay.PushReactable.Push() Method | struct' | 10                 |       490.7 ns |      3.04 ns |      2.70 ns |       490.9 ns |    0.1650 |     2.03 KB |
+| 'OneWay.PushReactable.Push() Method | int'    | 100                |    21,234.9 ns |    624.34 ns |  1,811.32 ns |    20,980.2 ns |   19.6838 |   241.41 KB |
+| 'OneWay.PushReactable.Push() Method | struct' | 100                |    13,944.0 ns |    641.75 ns |  1,882.16 ns |    12,927.1 ns |   13.1226 |   160.94 KB |
+| 'OneWay.PushReactable.Push() Method | int'    | 1000               | 1,361,815.1 ns | 26,895.61 ns | 70,381.13 ns | 1,328,702.9 ns | 1917.9688 | 23507.81 KB |
+| 'OneWay.PushReactable.Push() Method | struct' | 1000               |   977,922.6 ns | 14,818.57 ns | 13,861.30 ns |   973,509.8 ns | 1278.3203 | 15671.88 KB |
+
+---
+
+**Description:** Upgrade To CollectionsMarshal.AsSpan()
+
+| Method                                        | TotalSubscriptions | Mean        | Error     | StdDev    | Median      | Allocated |
+|---------------------------------------------- |------------------- |------------:|----------:|----------:|------------:|----------:|
+| 'OneWay.PushReactable.Push() Method | int'    | 10                 |    15.44 ns |  0.272 ns |  0.415 ns |    15.35 ns |         - |
+| 'OneWay.PushReactable.Push() Method | struct' | 10                 |    10.33 ns |  0.216 ns |  0.479 ns |    10.12 ns |         - |
+| 'OneWay.PushReactable.Push() Method | int'    | 100                |   123.69 ns |  2.451 ns |  2.724 ns |   123.16 ns |         - |
+| 'OneWay.PushReactable.Push() Method | struct' | 100                |    72.17 ns |  1.435 ns |  1.343 ns |    72.36 ns |         - |
+| 'OneWay.PushReactable.Push() Method | int'    | 1000               | 1,267.70 ns | 18.864 ns | 17.645 ns | 1,264.68 ns |         - |
+| 'OneWay.PushReactable.Push() Method | struct' | 1000               |   752.58 ns | 14.243 ns | 11.894 ns |   751.01 ns |         - |
diff --git a/Testing/CarbonatePerfTests/PrefResults/TwoWayPushPullReactable.md b/Testing/CarbonatePerfTests/PrefResults/TwoWayPushPullReactable.md
new file mode 100644
index 0000000..6ebbe6e
--- /dev/null
+++ b/Testing/CarbonatePerfTests/PrefResults/TwoWayPushPullReactable.md
@@ -0,0 +1,30 @@
+BenchmarkDotNet v0.13.11, Windows 11 (10.0.22631.3007/23H2/2023Update/SunValley3)
+12th Gen Intel Core i9-12900HK, 1 CPU, 20 logical and 14 physical cores
+.NET SDK 8.0.100
+[Host]     : .NET 8.0.0 (8.0.23.53103), X64 RyuJIT AVX2 [AttachedDebugger]
+DefaultJob : .NET 8.0.0 (8.0.23.53103), X64 RyuJIT AVX2
+
+
+**Description:** Baseline - Standard for loop
+
+| Method                                                 | TotalSubscriptions | Mean          | Error         | StdDev        | Gen0      | Allocated  |
+|------------------------------------------------------- |------------------- |--------------:|--------------:|--------------:|----------:|-----------:|
+| 'TwoWay.PushPullReactable<int, int>.PushPull()'        | 10                 |      66.79 ns |      1.359 ns |      1.565 ns |    0.0248 |      312 B |
+| 'TwoWay.PushPullReactable<int, StructItem>.PushPull()' | 10                 |     453.40 ns |      8.811 ns |     13.189 ns |    0.1736 |     2184 B |
+| 'TwoWay.PushPullReactable<int, int>.PushPull()'        | 100                |     191.63 ns |      3.814 ns |      7.961 ns |    0.1969 |     2472 B |
+| 'TwoWay.PushPullReactable<int, StructItem>.PushPull()' | 100                |  13,615.63 ns |    269.023 ns |    418.837 ns |   13.1989 |   165624 B |
+| 'TwoWay.PushPullReactable<int, int>.PushPull()'        | 1000               |   1,439.08 ns |     28.560 ns |     77.214 ns |    1.9169 |    24072 B |
+| 'TwoWay.PushPullReactable<int, StructItem>.PushPull()' | 1000               | 947,744.46 ns | 29,045.979 ns | 83,804.291 ns | 1279.2969 | 16056024 B |
+
+---
+
+**Description:** Upgrade To CollectionsMarshal.AsSpan()
+
+| Method                                                 | TotalSubscriptions | Mean       | Error      | StdDev    | Allocated |
+|------------------------------------------------------- |------------------- |-----------:|-----------:|----------:|----------:|
+| 'TwoWay.PushPullReactable<int, int>.PushPull()'        | 10                 |   2.643 ns |  0.0801 ns | 0.0857 ns |         - |
+| 'TwoWay.PushPullReactable<int, StructItem>.PushPull()' | 10                 |   7.184 ns |  0.1688 ns | 0.1579 ns |         - |
+| 'TwoWay.PushPullReactable<int, int>.PushPull()'        | 100                |   2.659 ns |  0.0795 ns | 0.0883 ns |         - |
+| 'TwoWay.PushPullReactable<int, StructItem>.PushPull()' | 100                |  56.799 ns |  1.0656 ns | 0.9967 ns |         - |
+| 'TwoWay.PushPullReactable<int, int>.PushPull()'        | 1000               |   2.671 ns |  0.0802 ns | 0.0955 ns |         - |
+| 'TwoWay.PushPullReactable<int, StructItem>.PushPull()' | 1000               | 725.182 ns | 10.1101 ns | 9.4570 ns |         - |
diff --git a/Testing/CarbonatePerfTests/Program.cs b/Testing/CarbonatePerfTests/Program.cs
index 796e4ce..6e8197c 100644
--- a/Testing/CarbonatePerfTests/Program.cs
+++ b/Testing/CarbonatePerfTests/Program.cs
@@ -2,43 +2,51 @@
 // Copyright (c) KinsonDigital. All rights reserved.
 // </copyright>
 
-namespace CarbonatePerfTests;
-
+#pragma warning disable SA1200
 // ReSharper disable RedundantUsingDirective
+// ReSharper disable JoinDeclarationAndInitializer
+using BenchmarkDotNet.Reports;
 using BenchmarkDotNet.Running;
-using CarbonatePerfTests;
-using Benchmarks;
-using MemPerfs;
-
-// ReSharper restore RedundantUsingDirective
-internal static class Program
-{
-    public static void Main()
-    {
+using CarbonatePerfTests.Benchmarks;
+
+#if RELEASE_NONDIRPUSHREACTABLE || RELEASE_ONEWAYPULLREACTABLE || RELEASE_ONEWAYPUSHREACTABLE || RELEASE_TWOWAYPUSHPULLREACTABLE
+Summary? summary;
+#endif
+
 #if DEBUG
-        Console.WriteLine("Add simple debugging code and manual testing here.");
+
+Console.WriteLine("Add simple debugging code and manual testing here.");
 
 #elif RELEASE
 
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine("WARNING!!");
-        Console.ForegroundColor = ConsoleColor.White;
-        Console.WriteLine("This application is for testing purposes only.");
-        Console.WriteLine("This can only be run with the following solution configuartions:");
-        Console.WriteLine("\t- Release Benchmark");
-        Console.WriteLine("\t- Release MemPerf");
+Console.ForegroundColor = ConsoleColor.Yellow;
+Console.WriteLine("WARNING!!");
+Console.ForegroundColor = ConsoleColor.White;
+Console.WriteLine("This application is for testing purposes only.");
+Console.WriteLine("This can only be run with the following solution configurations:");
+Console.WriteLine("\t- PullReactable");
+Console.WriteLine("\t- PushReactable");
+
+#elif RELEASE_NONDIRPUSHREACTABLE
 
-#elif RELEASE_BENCHMARK
+summary = BenchmarkRunner.Run<NonDir_PushReactable_Class>();
 
-        var summary = BenchmarkRunner.Run<PullReactable_Class>();
-        Console.WriteLine(summary);
+#elif RELEASE_ONEWAYPULLREACTABLE
 
-#elif RELEASE_MEMPERF
+summary = BenchmarkRunner.Run<OneWay_PullReactable_Class>();
 
-        // MemPerfRunner.Run(PerfScenarios.PullReactable_Pull_Method_With_Struct, -1);
-        MemPerfRunner.Run(PerfScenarios.PullReactable_Pull_Method_With_Ptr, -1);
+#elif RELEASE_ONEWAYPUSHREACTABLE
+
+summary = BenchmarkRunner.Run<OneWay_PushReactable_Class>();
+
+#elif RELEASE_TWOWAYPUSHPULLREACTABLE
+
+summary = BenchmarkRunner.Run<TwoWay_PushPullReactable_Class>();
 
 #endif
-        Console.ReadLine();
-    }
-}
+
+#if RELEASE_NONDIRPUSHREACTABLE || RELEASE_ONEWAYPULLREACTABLE || RELEASE_ONEWAYPUSHREACTABLE || RELEASE_TWOWAYPUSHPULLREACTABLE
+Console.WriteLine(summary);
+#endif
+
+Console.ReadLine();
diff --git a/Testing/CarbonatePerfTests/PtrDataPuller.cs b/Testing/CarbonatePerfTests/PtrDataPuller.cs
deleted file mode 100644
index 52d1693..0000000
--- a/Testing/CarbonatePerfTests/PtrDataPuller.cs
+++ /dev/null
@@ -1,28 +0,0 @@
-// <copyright file="PtrDataPuller.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests;
-
-using System.Runtime.CompilerServices;
-using Carbonate.OneWay;
-
-/// <summary>
-/// Used for perf testing.
-/// </summary>
-public class PtrDataPuller
-{
-    private readonly IPullReactable<nint> pullReactable;
-
-    public PtrDataPuller(IPullReactable<nint> pullReactable) => this.pullReactable = pullReactable;
-
-    public Span<StructItem> Pull()
-    {
-        var result = this.pullReactable.Pull(Ids.GetDatId);
-
-        unsafe
-        {
-            return Unsafe.AsRef<Memory<StructItem>>(result.ToPointer()).Span;
-        }
-    }
-}
diff --git a/Testing/CarbonatePerfTests/PtrDataStore.cs b/Testing/CarbonatePerfTests/PtrDataStore.cs
deleted file mode 100644
index dd06162..0000000
--- a/Testing/CarbonatePerfTests/PtrDataStore.cs
+++ /dev/null
@@ -1,44 +0,0 @@
-// <copyright file="PtrDataStore.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests;
-
-using System.Runtime.CompilerServices;
-using Carbonate.OneWay;
-
-public class PtrDataStore
-{
-    private Memory<StructItem> dataItems;
-
-    /// <summary>
-    /// Initializes a new instance of the <see cref="PtrDataStore"/> class.
-    /// </summary>
-    /// <param name="pullReactable">Pulls data from a source.</param>
-    public PtrDataStore(IPullReactable<nint> pullReactable)
-    {
-        var newDataItems = new StructItem[4];
-        newDataItems[0] = new StructItem { NumberValue = 10, StringValue = "ten" };
-        newDataItems[1] = new StructItem { NumberValue = 20, StringValue = "twenty" };
-        newDataItems[2] = new StructItem { NumberValue = 30, StringValue = "thirty" };
-        newDataItems[3] = new StructItem { NumberValue = 40, StringValue = "forty" };
-
-        this.dataItems = new Memory<StructItem>(newDataItems);
-
-        pullReactable.Subscribe(new RespondSubscription<nint>(
-            id: Ids.GetDatId,
-            onRespond: GetDataPtr));
-    }
-
-    /// <summary>
-    /// Gets the pointer data result.
-    /// </summary>
-    /// <returns>The result.</returns>
-    private nint GetDataPtr()
-    {
-        unsafe
-        {
-            return new nint(Unsafe.AsPointer(ref this.dataItems));
-        }
-    }
-}
diff --git a/Testing/CarbonatePerfTests/StructDataPuller.cs b/Testing/CarbonatePerfTests/StructDataPuller.cs
deleted file mode 100644
index 7e9cd2f..0000000
--- a/Testing/CarbonatePerfTests/StructDataPuller.cs
+++ /dev/null
@@ -1,22 +0,0 @@
-// <copyright file="StructDataPuller.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests;
-
-using Carbonate.OneWay;
-
-/// <summary>
-/// Used for per testing.
-/// </summary>
-public class StructDataPuller
-{
-    private readonly IPullReactable<StructItem[]> pullReactable;
-
-    public StructDataPuller(IPullReactable<StructItem[]> pullReactable) => this.pullReactable = pullReactable;
-
-    public StructItem[]? Pull()
-    {
-        return this.pullReactable.Pull(Ids.GetDatId);
-    }
-}
diff --git a/Testing/CarbonatePerfTests/StructDataStore.cs b/Testing/CarbonatePerfTests/StructDataStore.cs
deleted file mode 100644
index d14df55..0000000
--- a/Testing/CarbonatePerfTests/StructDataStore.cs
+++ /dev/null
@@ -1,37 +0,0 @@
-// <copyright file="StructDataStore.cs" company="KinsonDigital">
-// Copyright (c) KinsonDigital. All rights reserved.
-// </copyright>
-
-namespace CarbonatePerfTests;
-
-using Carbonate.OneWay;
-
-/// <summary>
-/// Used for performance testing.
-/// </summary>
-public class StructDataStore
-{
-    // ReSharper disable PrivateFieldCanBeConvertedToLocalVariable
-    private readonly Memory<StructItem> dataItems;
-
-    // ReSharper restore PrivateFieldCanBeConvertedToLocalVariable
-
-    /// <summary>
-    /// Initializes a new instance of the <see cref="StructDataStore"/> class.
-    /// </summary>
-    /// <param name="pullReactable">Pulls data from a source.</param>
-    public StructDataStore(IPullReactable<StructItem[]> pullReactable)
-    {
-        var newDataItems = new StructItem[4];
-        newDataItems[0] = new StructItem { NumberValue = 10, StringValue = "ten" };
-        newDataItems[1] = new StructItem { NumberValue = 20, StringValue = "twenty" };
-        newDataItems[2] = new StructItem { NumberValue = 30, StringValue = "thirty" };
-        newDataItems[3] = new StructItem { NumberValue = 40, StringValue = "forty" };
-
-        this.dataItems = new Memory<StructItem>(newDataItems);
-
-        pullReactable.Subscribe(new RespondSubscription<StructItem[]>(
-            id: Ids.GetDatId,
-            onRespond: () => this.dataItems.Span.ToArray()));
-    }
-}
diff --git a/Testing/CarbonatePerfTests/StructItem.cs b/Testing/CarbonatePerfTests/StructItem.cs
index 33ae1af..00d9644 100644
--- a/Testing/CarbonatePerfTests/StructItem.cs
+++ b/Testing/CarbonatePerfTests/StructItem.cs
@@ -11,6 +11,4 @@ namespace CarbonatePerfTests;
 public readonly struct StructItem
 {
     public int NumberValue { get; init; }
-
-    public string StringValue { get; init; }
 }
diff --git a/Testing/CarbonateTests/CarbonateTests.csproj b/Testing/CarbonateTests/CarbonateTests.csproj
index 1aa12e0..cd61dbd 100644
--- a/Testing/CarbonateTests/CarbonateTests.csproj
+++ b/Testing/CarbonateTests/CarbonateTests.csproj
@@ -7,7 +7,7 @@
         <Nullable>enable</Nullable>
         <IsPackable>false</IsPackable>
         <RootNamespace>CarbonateTests</RootNamespace>
-        <Configurations>Release;Debug</Configurations>
+        <Configurations>Release;Debug;Release OneWayPullReactable;Release OneWayPushReactable;Release NonDirPushReactable;Release TwoWayPushPullReactable</Configurations>
         <Platforms>x64</Platforms>
     </PropertyGroup>
 
diff --git a/Testing/CarbonateTests/Fluent/ReactableBuilderTests.cs b/Testing/CarbonateTests/Fluent/ReactableBuilderTests.cs
index a2acfad..98641ed 100644
--- a/Testing/CarbonateTests/Fluent/ReactableBuilderTests.cs
+++ b/Testing/CarbonateTests/Fluent/ReactableBuilderTests.cs
@@ -62,6 +62,24 @@ public void WhenUnsubscribing_WithNullParam_ThrowsException()
             .WithMessage("Value cannot be null. (Parameter 'onUnsubscribe')");
     }
 
+    [Fact]
+    public void WhenUnsubscribing_WhenInvoked_ReturnsCorrectResult()
+    {
+        // Arrange
+        var onSubscribingInvoked = false;
+        var sut = IReactableBuilder.Create();
+
+        // Act
+        (_, IPushReactable reactable) = sut.WithId(Guid.NewGuid())
+            .WhenUnsubscribing(() => onSubscribingInvoked = true)
+            .BuildPush(() => { });
+        reactable.Subscriptions[0].OnUnsubscribe();
+
+        // Assert
+        reactable.Should().NotBeNull();
+        onSubscribingInvoked.Should().BeTrue();
+    }
+
     [Fact]
     public void WithError_WithNullParam_ThrowsException()
     {
@@ -76,6 +94,24 @@ public void WithError_WithNullParam_ThrowsException()
             .WithMessage("Value cannot be null. (Parameter 'onError')");
     }
 
+    [Fact]
+    public void WithError_WhenInvoked_CorrectlySetsOnError()
+    {
+        // Arrange
+        var onErrorInvoked = false;
+        var sut = IReactableBuilder.Create();
+
+        // Act
+        (_, IPushReactable reactable) = sut
+            .WithId(Guid.NewGuid())
+            .WithError(_ => onErrorInvoked = true)
+            .BuildPush(() => { });
+        reactable.Subscriptions[0].OnError(new Exception("test-exception"));
+
+        // Assert
+        onErrorInvoked.Should().BeTrue();
+    }
+
     [Fact]
     public void BuildPush_WithNullParam_ThrowsException()
     {
diff --git a/Testing/CarbonateTests/Fluent/SubscriptionBuilderTests.cs b/Testing/CarbonateTests/Fluent/SubscriptionBuilderTests.cs
index 6f92d5a..df0e965 100644
--- a/Testing/CarbonateTests/Fluent/SubscriptionBuilderTests.cs
+++ b/Testing/CarbonateTests/Fluent/SubscriptionBuilderTests.cs
@@ -59,6 +59,24 @@ public void WhenUnsubscribing_WithNullParam_ThrowsException()
             .WithMessage("Value cannot be null. (Parameter 'onUnsubscribe')");
     }
 
+    [Fact]
+    public void WhenUnsubscribing_WhenInvoked_ReturnsCorrectResult()
+    {
+        // Arrange
+        var onSubscribingInvoked = false;
+        var sut = ISubscriptionBuilder.Create();
+
+        // Act
+        var subscription = sut.WithId(Guid.NewGuid())
+            .WhenUnsubscribing(() => onSubscribingInvoked = true)
+            .BuildOneWayReceive<int>(_ => { });
+        subscription.OnUnsubscribe();
+
+        // Assert
+        subscription.Should().NotBeNull();
+        onSubscribingInvoked.Should().BeTrue();
+    }
+
     [Fact]
     public void WithError_WithNullParam_ThrowsException()
     {
@@ -73,6 +91,24 @@ public void WithError_WithNullParam_ThrowsException()
             .WithMessage("Value cannot be null. (Parameter 'onError')");
     }
 
+    [Fact]
+    public void WithError_WhenInvoked_ReturnsCorrectResult()
+    {
+        // Arrange
+        var onErrorInvoked = false;
+        var sut = ISubscriptionBuilder.Create();
+
+        // Act
+        var subscription = sut.WithId(Guid.NewGuid())
+            .WithError(_ => onErrorInvoked = true)
+            .BuildOneWayReceive<int>(_ => { });
+        subscription.OnError(new Exception("test-exception"));
+
+        // Assert
+        subscription.Should().NotBeNull();
+        onErrorInvoked.Should().BeTrue();
+    }
+
     [Fact]
     public void BuildNonReceiveOrRespond_WithNullParam_ThrowsException()
     {
diff --git a/Testing/CarbonateTests/OneWay/PullReactableTests.cs b/Testing/CarbonateTests/OneWay/PullReactableTests.cs
index fdd6f31..fe2f101 100644
--- a/Testing/CarbonateTests/OneWay/PullReactableTests.cs
+++ b/Testing/CarbonateTests/OneWay/PullReactableTests.cs
@@ -47,6 +47,21 @@ public void Pull_WhenResponseIsNotNull_ReturnsCorrectResult()
         actual.Should().Be("return-value");
     }
 
+    [Fact]
+    public void Pull_WhenInvokedAfterDisposal_ThrowsException()
+    {
+        // Arrange
+        var sut = CreateSystemUnderTest();
+        sut.Dispose();
+
+        // Act
+        var act = () => sut.Pull(Guid.Empty);
+
+        // Assert
+        act.Should().Throw<ObjectDisposedException>()
+            .WithMessage($"{nameof(PullReactable<int>)} disposed.{Environment.NewLine}Object name: 'PullReactable'.");
+    }
+
     [Fact]
     public void Pull_WhenSubscriptionExists_InvokesCorrectSubscriptions()
     {
@@ -90,6 +105,27 @@ public void Pull_WhenSubscriptionDoesNotExist_ReturnsCorrectDefaultResult()
         // Assert
         actual.Should().BeNull();
     }
+
+    [Fact]
+    public void Pull_WhenPullingDataThatThrowsException_InvokesOnErrorSubscription()
+    {
+        // Arrange
+        var id = Guid.NewGuid();
+        var sut = CreateSystemUnderTest();
+
+        // Act & Assert
+        sut.Subscribe(new RespondSubscription<string>(
+                id: id,
+                name: "test-name",
+                onRespond: () => throw new Exception("test-exception"),
+                onError: e =>
+                {
+                    e.Should().NotBeNull();
+                    e.Message.Should().Be("test-exception");
+                }));
+
+        sut.Pull(id);
+    }
     #endregion
 
     /// <summary>
diff --git a/Testing/CarbonateTests/OneWay/PushReactableTests.cs b/Testing/CarbonateTests/OneWay/PushReactableTests.cs
index 50310c6..d91cf43 100644
--- a/Testing/CarbonateTests/OneWay/PushReactableTests.cs
+++ b/Testing/CarbonateTests/OneWay/PushReactableTests.cs
@@ -24,7 +24,7 @@ public void Push_WhenDataParamIsNull_ThrowsException()
         var sut = new PushReactable<object>();
 
         // Act
-        var act = () => sut.Push(null, Guid.NewGuid());
+        var act = () => sut.Push(Guid.NewGuid(), null);
 
         // Assert
         act.Should().Throw<ArgumentNullException>()
@@ -39,7 +39,7 @@ public void Push_WhenInvokedAfterDisposal_ThrowsException()
         sut.Dispose();
 
         // Act
-        var act = () => sut.Push(123, Guid.Empty);
+        var act = () => sut.Push(Guid.Empty, 123);
 
         // Assert
         act.Should().Throw<ObjectDisposedException>()
@@ -68,7 +68,7 @@ public void Push_WhenInvoking_NotifiesCorrectSubscriptionsThatMatchEventId()
         sut.Subscribe(mockSubC);
 
         // Act
-        sut.Push(123, invokedEventId);
+        sut.Push(invokedEventId, 123);
 
         // Assert
         mockSubA.Received(1).OnReceive(123);
@@ -109,7 +109,7 @@ public void Push_WhenUnsubscribingInsideOnReceiveSubscriptionAction_DoesNotThrow
         sut.Subscribe(initSubC);
 
         // Act
-        var act = () => sut.Push(data, mainId);
+        var act = () => sut.Push(mainId, data);
 
         // Assert
         act.Should().NotThrow<Exception>();
@@ -138,7 +138,7 @@ public void Push_WhenSubscriptionThrowsException_InvokesSubscriptionOnError()
         sut.Subscribe(subB);
 
         // Act
-        sut.Push(123, idA);
+        sut.Push(idA, 123);
     }
     #endregion
 
diff --git a/Testing/CarbonateTests/OneWay/RespondSubscriptionTests.cs b/Testing/CarbonateTests/OneWay/RespondSubscriptionTests.cs
index ed9aed4..0473338 100644
--- a/Testing/CarbonateTests/OneWay/RespondSubscriptionTests.cs
+++ b/Testing/CarbonateTests/OneWay/RespondSubscriptionTests.cs
@@ -142,7 +142,7 @@ public void OnError_WhenNotUnsubscribedAndWithNullParam_ThrowsException()
 
         // Assert
         act.Should().Throw<ArgumentNullException>()
-            .WithMessage("The parameter must not be null. (Parameter 'error')");
+            .WithMessage("Value cannot be null. (Parameter 'error')");
         totalActionInvokes.Should().Be(0);
     }
 
diff --git a/Testing/CarbonateTests/ReactableExtensionMethodsTests.cs b/Testing/CarbonateTests/ReactableExtensionMethodsTests.cs
index 1a7e017..dfd1930 100644
--- a/Testing/CarbonateTests/ReactableExtensionMethodsTests.cs
+++ b/Testing/CarbonateTests/ReactableExtensionMethodsTests.cs
@@ -564,5 +564,44 @@ public void CreateOneWayRespond_WhenInvokingWithIdAndAutoName_CreatesSubscriptio
         Assert.NotNull(unsubscriber);
         sut.SubscriptionIds.Should().BeEquivalentTo(expectedIds);
     }
+
+    [Theory]
+    [MemberData(nameof(SubscribeErrorData))]
+    [SuppressMessage("ReSharper", "ConvertToLocalFunction", Justification = "Not required for testing.")]
+    public void CreateTwoWay_WhenInvokingWithIdAndName_CreatesSubscription(Action? onUnsubscribe, Action<Exception>? onError)
+    {
+        // Arrange
+        var id = Guid.NewGuid();
+        var expectedIds = new[] { id }.AsReadOnly();
+        const string expectedName = "test-name";
+        Func<int, string> expectedAction = _ => "test-value";
+        var sut = new PushPullReactable<int, string>();
+
+        // Act
+        var unsubscriber = sut.CreateTwoWay(id, expectedName, expectedAction, onUnsubscribe, onError);
+
+        // Assert
+        Assert.NotNull(unsubscriber);
+        sut.SubscriptionIds.Should().BeEquivalentTo(expectedIds);
+    }
+
+    [Theory]
+    [MemberData(nameof(SubscribeErrorData))]
+    [SuppressMessage("ReSharper", "ConvertToLocalFunction", Justification = "Not required for testing.")]
+    public void CreateTwoWay_WhenInvokingWithIdAndAutoName_CreatesSubscription(Action? onUnsubscribe, Action<Exception>? onError)
+    {
+        // Arrange
+        var id = Guid.NewGuid();
+        var expectedIds = new[] { id }.AsReadOnly();
+        Func<int, string> expectedAction = _ => "test-value";
+        var sut = new PushPullReactable<int, string>();
+
+        // Act
+        var unsubscriber = sut.CreateTwoWay(id, expectedAction, onUnsubscribe, onError);
+
+        // Assert
+        Assert.NotNull(unsubscriber);
+        sut.SubscriptionIds.Should().BeEquivalentTo(expectedIds);
+    }
     #endregion
 }
diff --git a/Testing/CarbonateTests/SubscriptionBaseTests.cs b/Testing/CarbonateTests/SubscriptionBaseTests.cs
index 59e363e..f7a66ba 100644
--- a/Testing/CarbonateTests/SubscriptionBaseTests.cs
+++ b/Testing/CarbonateTests/SubscriptionBaseTests.cs
@@ -11,6 +11,21 @@ namespace CarbonateTests;
 
 public class SubscriptionBaseTests
 {
+    #region Constructor Tests
+    [Fact]
+    public void Ctor_WhenInvoked_SetsIdAndNameProps()
+    {
+        // Arrange & Act
+        var id = Guid.NewGuid();
+        var name = "test-name";
+        var sut = new SubscriptionBaseFake(id, name);
+
+        // Assert
+        sut.Id.Should().Be(id);
+        sut.Name.Should().Be(name);
+    }
+    #endregion
+
     #region Method Tests
     [Fact]
     public void OnUnsubscribe_WhenNotUnsubscribed_InvokesAction()
@@ -45,6 +60,20 @@ public void OnUnsubscribe_WhenUnsubscribed_DoesNotInvokeActionAgain()
         totalInvokes.Should().Be(1);
     }
 
+    [Fact]
+    public void OnError_WithNullErrorParameter_ThrowsException()
+    {
+        // Arrange
+        var sut = new ReceiveSubscription<int>(Guid.NewGuid(), _ => { }, onError: _ => { });
+
+        // Act
+        var act = () => sut.OnError(null);
+
+        // Assert
+        act.Should().Throw<ArgumentNullException>()
+            .WithMessage("Value cannot be null. (Parameter 'error')");
+    }
+
     [Fact]
     public void OnError_WhenNotUnsubscribed_InvokesAction()
     {
diff --git a/Testing/CarbonateTests/TwoWay/PushPullReactableTests.cs b/Testing/CarbonateTests/TwoWay/PushPullReactableTests.cs
index c0659aa..4cea0ea 100644
--- a/Testing/CarbonateTests/TwoWay/PushPullReactableTests.cs
+++ b/Testing/CarbonateTests/TwoWay/PushPullReactableTests.cs
@@ -40,7 +40,7 @@ public void Pull_WithMatchingSubscription_ReturnsCorrectResult()
         sut.Subscribe(mockSubB);
 
         // Act
-        var actual = sut.PushPull(data, respondIdB);
+        var actual = sut.PushPull(respondIdB, data);
 
         // Assert
         mockSubA.DidNotReceive().OnRespond(321);
@@ -50,6 +50,21 @@ public void Pull_WithMatchingSubscription_ReturnsCorrectResult()
         actual.Should().Be("return-value");
     }
 
+    [Fact]
+    public void PushPull_WhenInvokedAfterDisposal_ThrowsException()
+    {
+        // Arrange
+        var sut = CreateSystemUnderTest();
+        sut.Dispose();
+
+        // Act
+        var act = () => sut.PushPull(Guid.Empty, 123);
+
+        // Assert
+        act.Should().Throw<ObjectDisposedException>()
+            .WithMessage($"{nameof(PushPullReactable<int, string>)} disposed.{Environment.NewLine}Object name: 'PushPullReactable'.");
+    }
+
     [Fact]
     public void Pull_WithNoMatchingSubscription_ReturnsCorrectResult()
     {
@@ -57,11 +72,32 @@ public void Pull_WithNoMatchingSubscription_ReturnsCorrectResult()
         var sut = new PushPullReactable<int, int>();
 
         // Act
-        var actual = sut.PushPull(123, Guid.NewGuid());
+        var actual = sut.PushPull(Guid.NewGuid(), 123);
 
         // Assert
         actual.Should().Be(0);
     }
+
+    [Fact]
+    public void Pull_WhenPullingDataThatThrowsException_InvokesOnErrorSubscription()
+    {
+        // Arrange
+        var id = Guid.NewGuid();
+        var sut = CreateSystemUnderTest();
+
+        // Act & Assert
+        sut.Subscribe(new ReceiveRespondSubscription<int, string>(
+            id: id,
+            name: "test-name",
+            onReceiveRespond: _ => throw new Exception("test-exception"),
+            onError: e =>
+            {
+                e.Should().NotBeNull();
+                e.Message.Should().Be("test-exception");
+            }));
+
+        sut.PushPull(id, 123);
+    }
     #endregion
 
     /// <summary>
diff --git a/Testing/CarbonateTests/TwoWay/ReceiveRespondSubscriptionTests.cs b/Testing/CarbonateTests/TwoWay/ReceiveRespondSubscriptionTests.cs
index 6789758..1d5778e 100644
--- a/Testing/CarbonateTests/TwoWay/ReceiveRespondSubscriptionTests.cs
+++ b/Testing/CarbonateTests/TwoWay/ReceiveRespondSubscriptionTests.cs
@@ -57,6 +57,20 @@ public void OnRespond_WhenUnsubscribed_ReturnsCorrectDefaultResult()
         actual.Should().Be(0);
     }
 
+    [Fact]
+    public void OnRespond_WhenInvokingWithNullData_ThrowsException()
+    {
+        // Arrange
+        var sut = new ReceiveRespondSubscription<int?, object>(Guid.NewGuid(), _ => new object());
+
+        // Act
+        var act = () => sut.OnRespond(null);
+
+        // Assert
+        act.Should().Throw<ArgumentNullException>()
+            .WithMessage("Value cannot be null. (Parameter 'data')");
+    }
+
     [Fact]
     public void OnRespond_WhenOnRespondDataIsNotNull_ReturnsCorrectResult()
     {
@@ -129,7 +143,7 @@ public void OnError_WhenNotUnsubscribedAndWithNullParam_ThrowsException()
 
         // Assert
         act.Should().Throw<ArgumentNullException>()
-            .WithMessage("The parameter must not be null. (Parameter 'error')");
+            .WithMessage("Value cannot be null. (Parameter 'error')");
         totalActionInvokes.Should().Be(0);
     }