reactor.bus

Interface Bus<T>

All Known Implementing Classes:

EventBus

public interface Bus<T>

Basic unit of event handling in Reactor.

Author:

Jon Brisbin, Stephane Maldini, Andy Wilkinson

Method Summary

Modifier and Type	Method and Description
Bus	notify(Object key, T ev) Notify this component that an Event is ready to be processed.
<V extends T> Registration<Object,Consumer<? extends T>>	on(Selector selector, Consumer<V> consumer) Register a Consumer to be triggered when a notification matches the given Selector.
boolean	respondsToKey(Object key) Are there any Registrations with Selectors that match the given key.

Method Detail

respondsToKey

boolean respondsToKey(Object key)

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

Parameters:

key - The key to be matched by Selectors

Returns:

true if there are any matching Registrations, false otherwise

on

<V extends T> Registration<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 Registration object that allows the caller to interact with the given mapping

notify

Bus notify(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