PendingEvent destructor clean up - properly delete typed Events in dtor ( came up in valgrind )

Signed-off-by: Rob Ambalu <robert.ambalu@point72.com>

Author: robambalu

cpp/csp/engine/PendingPushEvents.cpp

@@ -17,7 +17,7 @@ PendingPushEvents::~PendingPushEvents()
         while( e )
         {
             PushEvent * next = e -> next;
-            delete e;
+            deleteEvent( e );
             e = next;
         }
     }
@@ -28,12 +28,21 @@ PendingPushEvents::~PendingPushEvents()
         while( e )
         {
             PushEvent * next = e -> next;
-            delete e;
+            deleteEvent( e );
             e = next;
         }
     }
 }
 
+void PendingPushEvents::deleteEvent( PushEvent * event )
+{
+    switchCspType( event -> adapter() -> dataType(),
+                   [ event ]( auto tag ) {
+                       using T = typename decltype(tag)::type;
+                       delete static_cast<TypedPushEvent<T> *>( event );
+                   } );
+}
+
 void PendingPushEvents::addPendingEvent( PushEvent * event )
 {
     PushInputAdapter * adapter = event -> adapter();

cpp/csp/engine/PendingPushEvents.h

@@ -38,6 +38,8 @@ class PendingPushEvents
     //backed up input ( if we merged adaptrers into one list we would have to rescan every cycle )
     using UngroupedEvents = std::unordered_map<PushInputAdapter*,EventList>;
 
+    void deleteEvent( PushEvent * event );
+    
     UngroupedEvents m_ungroupedEvents;
     GroupEvents     m_groupedEvents;
 };