README.md

@@ -27,6 +27,7 @@ package main
 
 import (
 	"fmt"
+	"sync"
 
 	"git.apihub24.de/admin/events"
 )
@@ -54,14 +55,15 @@ func main() {
 
 	nameSubscription := handler.Subscribe(NameEventType, func(event events.IEvent) {
 		// read the Name Event Data
-		data, _ := events.ParseEventData[NameEventData](event)
+		var data NameEventData
+		_ = event.Data(&data)
 		// Publish the Greet Event
 		_ = handler.Publish(events.NewEvent(GreetEventType, GreetEventData{Greeting: fmt.Sprintf("Hello, %s", data.Name)}))
 	})
 
 	greetSubscription := handler.Subscribe(GreetEventType, func(event events.IEvent) {
-		data, _ := events.ParseEventData[GreetEventData](event)
+		var data GreetEventData
-		println(fmt.Sprintf("%v", data))
+		_ = event.Data(&data)
 	})
 	// publish the Name Event
 	_ = handler.Publish(nameEvent)

helper.go

@@ -1,7 +0,0 @@
-package events
-
-func ParseEventData[T any](event IEvent) (T, error) {
-	var d T
-	err := event.Data(&d)
-	return d, err
-}

test/handler_test.go

@@ -29,7 +29,8 @@ func Test_EventHandler_ShouldHandleSubscriptions(t *testing.T) {
 	wg.Add(2)
 
 	handler.Subscribe(NameEventType, func(event events.IEvent) {
-		data, err := events.ParseEventData[NameEventData](event)
+		var data NameEventData
+		err := event.Data(&data)
 		if err != nil {
 			t.Error(err)
 		}
@@ -41,7 +42,8 @@ func Test_EventHandler_ShouldHandleSubscriptions(t *testing.T) {
 	})
 
 	handler.Subscribe(GreetEventType, func(event events.IEvent) {
-		data, err := events.ParseEventData[GreetEventData](event)
+		var data GreetEventData
+		err := event.Data(&data)
 		if err != nil {
 			t.Error(err)
 		}