Package reactor.bus

Interface Bus<T>

@Deprecated public interface Bus<T>
Deprecated.
Here for compatibility only. Do not use directly
Basic unit of event handling in Reactor.

  • Method Summary

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

  • Method Details

    • respondsToKey

      boolean respondsToKey(Object key)
      Deprecated.
      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

    • on

      <V extends T> reactor.bus.registry.Subscription<Object,Consumer<? extends T>> on(Selector selector, Consumer<V> consumer)
      Deprecated.
      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

    • notify

      Bus notify(Object key, T ev)
      Deprecated.
      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