From a4a3057f392f32527097c31c60b207b7a4901ddf Mon Sep 17 00:00:00 2001
From: Robinson <robinson@dorkbox.com>
Date: Mon, 26 Jul 2021 20:18:04 +0200
Subject: [PATCH] Added comments. Fixed onErrorGlobal (it is now a separate
 name, since the function signatures had issues), made it a unit function
 instead of method, so it can be passed around

---
 src/dorkbox/network/connection/EndPoint.kt | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/dorkbox/network/connection/EndPoint.kt b/src/dorkbox/network/connection/EndPoint.kt
index bb59c215..5b918a05 100644
--- a/src/dorkbox/network/connection/EndPoint.kt
+++ b/src/dorkbox/network/connection/EndPoint.kt
@@ -127,7 +127,7 @@ internal constructor(val type: Class<*>,
 
     init {
         require(!config.previouslyUsed) { "${type.simpleName} configuration cannot be reused!" }
-        config.validate()
+        config.validate() // this happens more than once! (this is ok)
 
         // serialization stuff
         @Suppress("UNCHECKED_CAST")
@@ -147,7 +147,7 @@ internal constructor(val type: Class<*>,
 
         // Only starts the media driver if we are NOT already running!
         try {
-            aeronDriver = AeronDriver(config, type, logger)
+            aeronDriver = AeronDriver(config, type, logger, listenerManager.notifyError)
         } catch (e: Exception) {
             logger.error("Error initialize endpoint", e)
             throw e
@@ -281,11 +281,11 @@ internal constructor(val type: Class<*>,
     }
 
     /**
-     * Called when there is an error in general
+     * Called when there is a global error (and error that is not specific to a connection)
      *
      * The error is also sent to an error log before this method is called.
      */
-    fun onError(function: Throwable.() -> Unit) {
+    fun onErrorGlobal(function: (Throwable) -> Unit) {
         actionDispatch.launch {
             listenerManager.onError(function)
         }