MCPcopy Create free account
hub / github.com/chainreactors/EvilProxy / SubscribeErrors

Function SubscribeErrors

internal/redisqueue/queue.go:102–104  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

100}
101
102func SubscribeErrors() (<-chan []byte, func()) {
103 return errorGlobal.subscribe(errorSubscriberBuffer, nil)
104}
105
106func NotifyUsageRefresh() {
107 global.publishToSubscribers([]byte(usageRefreshPayload))

Callers 6

subscribeRedisChannelFunction · 0.92
TestManagerMarkResultPublishesErrorEventAfterAuthStateUpdateFunction · 0.92
TestManagerMarkResultSkipsErrorEventInHomeModeFunction · 0.92
TestSetEnabledFalseClosesUsageSubscribersFunction · 0.85
TestEnqueueErrorBroadcastsToErrorSubscribersAndDiscardsWithoutSubscribersFunction · 0.85
TestNotifyUsageRefreshBroadcastsOnlyToUsageSubscribersFunction · 0.85

Calls 1

subscribeMethod · 0.80

Tested by 5

TestManagerMarkResultPublishesErrorEventAfterAuthStateUpdateFunction · 0.74
TestManagerMarkResultSkipsErrorEventInHomeModeFunction · 0.74
TestSetEnabledFalseClosesUsageSubscribersFunction · 0.68
TestEnqueueErrorBroadcastsToErrorSubscribersAndDiscardsWithoutSubscribersFunction · 0.68
TestNotifyUsageRefreshBroadcastsOnlyToUsageSubscribersFunction · 0.68