MCPcopy Create free account
hub / github.com/riverqueue/river / runOnceSchedule

Struct runOnceSchedule

client_test.go:6298–6300  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

6296}
6297
6298type runOnceSchedule struct {
6299 ran atomic.Bool
6300}
6301
6302func (s *runOnceSchedule) Next(time.Time) time.Time {
6303 if !s.ran.Swap(true) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected