From 30943ded71e123886291ad393e55bfb6aa837df3 Mon Sep 17 00:00:00 2001 From: Chris Wendt Date: Wed, 8 Jun 2022 02:28:37 -0600 Subject: BIG change: generic Var[T], txVar, etc. --- stmutil/context.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'stmutil') diff --git a/stmutil/context.go b/stmutil/context.go index 8a4d58d..9d23e12 100644 --- a/stmutil/context.go +++ b/stmutil/context.go @@ -9,12 +9,12 @@ import ( var ( mu sync.Mutex - ctxVars = map[context.Context]*stm.Var{} + ctxVars = map[context.Context]*stm.Var[bool]{} ) // Returns an STM var that contains a bool equal to `ctx.Err != nil`, and a cancel function to be // called when the user is no longer interested in the var. -func ContextDoneVar(ctx context.Context) (*stm.Var, func()) { +func ContextDoneVar(ctx context.Context) (*stm.Var[bool], func()) { mu.Lock() defer mu.Unlock() if v, ok := ctxVars[ctx]; ok { @@ -26,7 +26,7 @@ func ContextDoneVar(ctx context.Context) (*stm.Var, func()) { v := stm.NewBuiltinEqVar(true) return v, func() {} } - v := stm.NewVar(false) + v := stm.NewVar[bool](false) go func() { <-ctx.Done() stm.AtomicSet(v, true) -- cgit v1.2.3