MCPcopy Create free account
hub / github.com/IceFireDB/IceFireDB / Next

Method Next

IceFireDB-PubSub/pkg/router/context.go:49–59  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

47}
48
49func (c *Context) Next() error {
50 c.Index++
51 for c.Index < int8(len(c.Handlers)) {
52 err := c.Handlers[c.Index](c)
53 if err != nil {
54 return err
55 }
56 c.Index++
57 }
58 return nil
59}
60
61// IsAborted returns true if the current context was aborted.
62func (c *Context) IsAborted() bool {

Callers 10

handleInboundMethod · 0.45
SubLoopMethod · 0.45
ExecFunction · 0.45
SubLoopMethod · 0.45
PubSubMiddlewareFunction · 0.45
IgnoreCMDMiddlewareFunction · 0.45
NamespaceFunction · 0.45
HandleMethod · 0.45
SyncMethod · 0.45
HandleMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected