other: 示例及 buffer README.md 更新

This commit is contained in:
kercylan98 2023-12-23 18:16:01 +08:00
parent eb28d42bf1
commit c3e1581289
3 changed files with 6 additions and 8 deletions

View File

@ -1,16 +1,14 @@
package main package main
import ( import (
"fmt"
"github.com/kercylan98/minotaur/server" "github.com/kercylan98/minotaur/server"
) )
func main() { func main() {
srv := server.New(server.NetworkWebsocket, srv := server.New(server.NetworkWebsocket)
server.WithShunt(func(conn *server.Conn) string { srv.RegConnectionOpenedEvent(func(srv *server.Server, conn *server.Conn) {
return fmt.Sprint(conn.GetData("roomId")) srv.UseShunt(conn, conn.GetData("room_id").(string))
}), })
)
srv.RegConnectionReceivePacketEvent(func(srv *server.Server, conn *server.Conn, packet []byte) { srv.RegConnectionReceivePacketEvent(func(srv *server.Server, conn *server.Conn, packet []byte) {
conn.Write(packet) conn.Write(packet)
}) })

View File

@ -48,7 +48,7 @@ import (
) )
func main() { func main() {
unbounded := buffer.NewUnboundedN[int]() unbounded := buffer.NewUnbounded[int]()
for i := 0; i < 10; i++ { for i := 0; i < 10; i++ {
unbounded.Put(i) unbounded.Put(i)
} }

View File

@ -16,5 +16,5 @@ func TestNewStateLine(t *testing.T) {
return true return true
}) })
t.Log(sl.GetState(time.Now())) t.Log(sl.GetStateByTime(time.Now()))
} }