Merge pull request #3 from lxzan/dev

Project Refactoring

Author: lxzan

README.md

@@ -16,33 +16,65 @@
 go get -v github.com/lxzan/event_emitter@latest
 ```
 
-### Usage
+### Quick Start
 
 ```go
 package main
 
 import (
-	"context"
 	"fmt"
 	"github.com/lxzan/event_emitter"
-	"time"
 )
 
 func main() {
-	var em = event_emitter.New(&event_emitter.Config{
-		BucketNum:   16,
-		BucketCap:   128,
-		Concurrency: 8,
+	var em = event_emitter.New[event_emitter.Int64Subscriber](&event_emitter.Config{
+		BucketNum:  16,
+		BucketSize: 128,
 	})
-	em.Subscribe(em.NewSubscriber(), "greet", func(msg any) {
-		fmt.Printf("recv: %v\n", msg)
+
+	var suber1 = em.NewSubscriber()
+	em.Subscribe(suber1, "greet", func(subscriber event_emitter.Int64Subscriber, msg any) {
+		fmt.Printf("recv: sub_id=%d, msg=%v\n", subscriber.GetSubscriberID(), msg)
+	})
+	em.Subscribe(suber1, "greet1", func(subscriber event_emitter.Int64Subscriber, msg any) {
+		fmt.Printf("recv: sub_id=%d, msg=%v\n", subscriber.GetSubscriberID(), msg)
 	})
-	em.Subscribe(em.NewSubscriber(), "greet", func(msg any) {
-		fmt.Printf("recv: %v\n", msg)
+
+	var suber2 = em.NewSubscriber()
+	em.Subscribe(suber2, "greet1", func(subscriber event_emitter.Int64Subscriber, msg any) {
+		fmt.Printf("recv: sub_id=%d, msg=%v\n", subscriber.GetSubscriberID(), msg)
 	})
-	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
-	defer cancel()
-	_ = em.Publish(ctx, "greet", "hello!")
-	time.Sleep(time.Second)
+
+	em.Publish("greet1", "hello!")
+}
+```
+
+### GWS Broadcast
+
+```go
+package main
+
+import (
+	"github.com/lxzan/event_emitter"
+	"github.com/lxzan/gws"
+)
+
+type Socket struct{ *gws.Conn }
+
+func (c *Socket) GetSubscriberID() int64 {
+	userId, _ := c.Session().Load("userId")
+	return userId.(int64)
+}
+
+func Sub(em *event_emitter.EventEmitter[*Socket], topic string, socket *Socket) {
+	em.Subscribe(socket, topic, func(subscriber *Socket, msg any) {
+		_ = msg.(*gws.Broadcaster).Broadcast(subscriber.Conn)
+	})
+}
+
+func Pub(em *event_emitter.EventEmitter[*Socket], topic string, op gws.Opcode, msg []byte) {
+	var broadcaster = gws.NewBroadcaster(op, msg)
+	defer broadcaster.Close()
+	em.Publish(topic, broadcaster)
 }
 ```