Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
0f28e3d11b
|
|||
|
55f80432bb
|
@@ -97,3 +97,9 @@ func (mm *MultiMutex[TKey]) Get(key TKey) sync.Locker {
|
|||||||
lck := mm.mutextMap.GetAndSetIfNotContainsFunc(key, NewCASMutex)
|
lck := mm.mutextMap.GetAndSetIfNotContainsFunc(key, NewCASMutex)
|
||||||
return lck
|
return lck
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GetCAS returns the underlying CASMutex
|
||||||
|
func (mm *MultiMutex[TKey]) GetCAS(key TKey) *CASMutex {
|
||||||
|
lck := mm.mutextMap.GetAndSetIfNotContainsFunc(key, NewCASMutex)
|
||||||
|
return lck
|
||||||
|
}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
package goext
|
package goext
|
||||||
|
|
||||||
const GoextVersion = "0.0.616"
|
const GoextVersion = "0.0.618"
|
||||||
|
|
||||||
const GoextVersionTimestamp = "2025-12-06T11:53:59+0100"
|
const GoextVersionTimestamp = "2025-12-06T22:20:02+0100"
|
||||||
|
|||||||
@@ -1,13 +1,11 @@
|
|||||||
package scn
|
package scn
|
||||||
|
|
||||||
type Connection struct {
|
type Connection struct {
|
||||||
uid string
|
|
||||||
token string
|
token string
|
||||||
}
|
}
|
||||||
|
|
||||||
func New(userid string, token string) *Connection {
|
func New(token string) *Connection {
|
||||||
return &Connection{
|
return &Connection{
|
||||||
uid: userid,
|
|
||||||
token: token,
|
token: token,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -88,7 +88,6 @@ func (c *MessageBuilder) Send(ctx context.Context) (MessageResponse, error) {
|
|||||||
|
|
||||||
body := langext.H{}
|
body := langext.H{}
|
||||||
|
|
||||||
body["user_id"] = c.conn.uid
|
|
||||||
body["key"] = c.conn.token
|
body["key"] = c.conn.token
|
||||||
|
|
||||||
if c.channel != nil {
|
if c.channel != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user