From 6f7868483f6d0932f4906ba1b69217e5703a08b3 Mon Sep 17 00:00:00 2001 From: kercylan98 Date: Fri, 12 Jan 2024 16:34:28 +0800 Subject: [PATCH] =?UTF-8?q?test:=20dispatcher=20=E5=8C=85=E5=AE=8C?= =?UTF-8?q?=E5=96=84=E6=B5=8B=E8=AF=95=E7=94=A8=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dispatcher/manager_example_test.go | 23 +++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 server/internal/dispatcher/manager_example_test.go diff --git a/server/internal/dispatcher/manager_example_test.go b/server/internal/dispatcher/manager_example_test.go new file mode 100644 index 0000000..ed24de1 --- /dev/null +++ b/server/internal/dispatcher/manager_example_test.go @@ -0,0 +1,23 @@ +package dispatcher_test + +import ( + "fmt" + "github.com/kercylan98/minotaur/server/internal/dispatcher" +) + +func ExampleNewManager() { + mgr := dispatcher.NewManager[string, *TestMessage](10124*16, func(dispatcher *dispatcher.Dispatcher[string, *TestMessage], message *TestMessage) { + // do something + }) + mgr.BindProducer("player_001", "shunt-001") + mgr.BindProducer("player_002", "shunt-002") + mgr.BindProducer("player_003", "shunt-sys") + mgr.BindProducer("player_004", "shunt-sys") + mgr.UnBindProducer("player_001") + mgr.UnBindProducer("player_002") + mgr.UnBindProducer("player_003") + mgr.UnBindProducer("player_004") + mgr.Wait() + fmt.Println("done") + // Output: done +}