MCPcopy
hub / github.com/nats-io/nats.go / isRunningInAsyncCBDispatcher

Function isRunningInAsyncCBDispatcher

test/conn_test.go:873–879  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

871}
872
873func isRunningInAsyncCBDispatcher() error {
874 strStacks := getStacks(false)
875 if strings.Contains(strStacks, "asyncCBDispatcher") {
876 return nil
877 }
878 return fmt.Errorf("callback not executed from dispatcher:\n %s", strStacks)
879}
880
881func isAsyncDispatcherRunning() bool {
882 strStacks := getStacks(true)

Callers 1

TestCallbacksOrderFunction · 0.85

Calls 2

getStacksFunction · 0.85
ErrorfMethod · 0.80

Tested by

no test coverage detected