Method Detail

• public Bus notify(java.lang.Object key, T ev)

  Notify this component that an Event is ready to be processed.

  Parameters:

  key - The key to be matched by Selectors

  ev - The Event

  Returns:

  this

• <V extends T> public Subscription<java.lang.Object, Consumer<? extends T>> on(Selector selector, Consumer<V> consumer)

  Register a Consumer to be triggered when a notification matches the given Selector.

  Parameters:

  selector - The Selector to be used for matching

  consumer - The Consumer to be triggered

  Returns:

  A Subscription object that allows the caller to interact with the given mapping

• public boolean respondsToKey(java.lang.Object key)

  Are there any Subscriptions with Selectors that match the given key.

  Parameters:

  key - The key to be matched by Selectors

  Returns:

  true if there are any matching Subscriptions, false otherwise