You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Broadcaster distributing to a set of filtered sinks is fairly efficient in practice but still requires O(N) for every message sent. Provide the following interface definition to allow implementation of efficient event dispatch:
funcNewDispatcher(selectorSelector) *DispatchertypeSelectorinterface {
// Select zero or more sinks on which the event should be sent.Select(eventEvent) []Sink
}
This will allow events to be dispatched to a large set of listeners without incurring O(N) overhead for all messages.
This can also be used to implement load balancing of messages to support worker queues.
The text was updated successfully, but these errors were encountered:
Broadcaster
distributing to a set of filtered sinks is fairly efficient in practice but still requiresO(N)
for every message sent. Provide the following interface definition to allow implementation of efficient event dispatch:This will allow events to be dispatched to a large set of listeners without incurring
O(N)
overhead for all messages.This can also be used to implement load balancing of messages to support worker queues.
The text was updated successfully, but these errors were encountered: