diff options
| author | EuAndreh <eu@euandre.org> | 2025-05-23 10:11:01 -0300 |
|---|---|---|
| committer | EuAndreh <eu@euandre.org> | 2025-05-23 10:11:13 -0300 |
| commit | ecd7797abb3b43226532b0bace7ba9f1e5ac277d (patch) | |
| tree | 11ebec15b24497a3cceea593c9501f1f38f0569e | |
| parent | meta.capim: Add with :dependencies key (diff) | |
| download | papod-ecd7797abb3b43226532b0bace7ba9f1e5ac277d.tar.gz papod-ecd7797abb3b43226532b0bace7ba9f1e5ac277d.tar.xz | |
src/papod.go: Use stm.AtomT over stm.Var
| -rw-r--r-- | src/papod.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/papod.go b/src/papod.go index 7e422f7..b50729b 100644 --- a/src/papod.go +++ b/src/papod.go @@ -276,7 +276,7 @@ type papodT struct{ listeners listenersT consumers []consumerT stateMutable stateMutableT - state *stm.Var[*stateT] + state *stm.AtomT[*stateT] metrics metricsT // logger g.Logger } @@ -3706,7 +3706,7 @@ func NewWithPrefix( listeners: listeners, consumers: consumers, stateMutable: stateMutable, - state: stm.NewVar[*stateT](state), + state: stm.Atom(state), // receivers: receivers, metrics: metrics, // logger: logger, @@ -4123,7 +4123,7 @@ func handlePRIVMSG( go broadcastMessage( msg, msg.params[0], - stm.Deref(papod.state), + papod.state.Deref(), ) return []replyT{}, false, nil } |