MCPcopy
hub / github.com/redis/go-redis / ProcessPendingNotifications

Method ProcessPendingNotifications

push/processor.go:17–17  ·  view source on GitHub ↗

ProcessPendingNotifications checks for and processes any pending push notifications. To be used when it is known that there are notifications on the socket. It will try to read from the socket and if it is empty - it may block.

(ctx context.Context, handlerCtx NotificationHandlerContext, rd *proto.Reader)

Source from the content-addressed store, hash-verified

15 // To be used when it is known that there are notifications on the socket.
16 // It will try to read from the socket and if it is empty - it may block.
17 ProcessPendingNotifications(ctx context.Context, handlerCtx NotificationHandlerContext, rd *proto.Reader) error
18 // RegisterHandler registers a handler for a specific push notification name.
19 RegisterHandler(pushNotificationName string, handler NotificationHandler, protected bool) error
20 // UnregisterHandler removes a handler for a specific push notification name.

Implementers 2

Processorpush/processor.go
VoidProcessorpush/processor.go

Calls

no outgoing calls

Tested by

no test coverage detected