diff --git a/examples/internal/room-shunt-server/main.go b/examples/internal/room-shunt-server/main.go index cf7d8ec..749874d 100644 --- a/examples/internal/room-shunt-server/main.go +++ b/examples/internal/room-shunt-server/main.go @@ -1,16 +1,14 @@ package main import ( - "fmt" "github.com/kercylan98/minotaur/server" ) func main() { - srv := server.New(server.NetworkWebsocket, - server.WithShunt(func(conn *server.Conn) string { - return fmt.Sprint(conn.GetData("roomId")) - }), - ) + srv := server.New(server.NetworkWebsocket) + srv.RegConnectionOpenedEvent(func(srv *server.Server, conn *server.Conn) { + srv.UseShunt(conn, conn.GetData("room_id").(string)) + }) srv.RegConnectionReceivePacketEvent(func(srv *server.Server, conn *server.Conn, packet []byte) { conn.Write(packet) }) diff --git a/utils/buffer/README.md b/utils/buffer/README.md index 969dec4..461eb1f 100644 --- a/utils/buffer/README.md +++ b/utils/buffer/README.md @@ -48,7 +48,7 @@ import ( ) func main() { - unbounded := buffer.NewUnboundedN[int]() + unbounded := buffer.NewUnbounded[int]() for i := 0; i < 10; i++ { unbounded.Put(i) } diff --git a/utils/times/line_test.go b/utils/times/line_test.go index e4b6eff..e82bb11 100644 --- a/utils/times/line_test.go +++ b/utils/times/line_test.go @@ -16,5 +16,5 @@ func TestNewStateLine(t *testing.T) { return true }) - t.Log(sl.GetState(time.Now())) + t.Log(sl.GetStateByTime(time.Now())) }