reactor.groovy.ext

Class BusExtensions

java.lang.Object

reactor.groovy.ext.BusExtensions

All Implemented Interfaces:

groovy.lang.GroovyObject

@CompileStatic
public class BusExtensions
extends Object
implements groovy.lang.GroovyObject

Constructor Summary

Constructors

Constructor and Description
BusExtensions()

Method Summary

Modifier and Type	Method and Description
static <T> void	call(Consumer<T> selfType, T value)
static <T,V> void	call(Function<T,V> selfType, T value)
static <T> void	call(Supplier<T> selfType)
static String	getARG_DATA()
static String	getARG_TOPIC()
groovy.lang.MetaClass	getMetaClass()
Object	getProperty(String property)
Object	invokeMethod(String method, Object arguments)
static Bus	notify(Bus selfType, Map params)
static Bus	notify(Bus selfType, Object key)
static <T> Bus	notify(Bus selfType, Object key, Supplier<Event<T>> obj)
static <T> Bus	notify(Bus selfType, Object key, T obj)
static <T> Bus	notify(Bus selfType, String key, groovy.lang.Closure<T> closure)
static <K,T> Registration<K,Consumer<T>>	react(EventBus selfType, Selector<K> selector, groovy.lang.Closure handler)
static <T> Registration<String,Consumer<T>>	react(EventBus selfType, String selector, groovy.lang.Closure handler)
static <T> EventBus	send(EventBus selfType, Object key, Event<T> obj, groovy.lang.Closure handler)
static <T> EventBus	send(EventBus selfType, Object key, T obj)
static <T> EventBus	send(EventBus selfType, Object key, T obj, groovy.lang.Closure handler)
void	setMetaClass(groovy.lang.MetaClass mc)
void	setProperty(String property, Object value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BusExtensions

public BusExtensions()

Method Detail

getMetaClass

public groovy.lang.MetaClass getMetaClass()

Specified by:

getMetaClass in interface groovy.lang.GroovyObject

setMetaClass

public void setMetaClass(groovy.lang.MetaClass mc)

Specified by:

setMetaClass in interface groovy.lang.GroovyObject

invokeMethod

public Object invokeMethod(String method,
                           Object arguments)

Specified by:

invokeMethod in interface groovy.lang.GroovyObject

getProperty

public Object getProperty(String property)

Specified by:

getProperty in interface groovy.lang.GroovyObject

setProperty

public void setProperty(String property,
                        Object value)

Specified by:

setProperty in interface groovy.lang.GroovyObject

getARG_DATA

public static final String getARG_DATA()

getARG_TOPIC

public static final String getARG_TOPIC()

react

public static <K,T> Registration<K,Consumer<T>> react(EventBus selfType,
                                                      Selector<K> selector,
                                                      @DelegatesTo(strategy=1,value=ClosureEventConsumer.ReplyDecorator.class)
                                                      groovy.lang.Closure handler)

react

public static <T> Registration<String,Consumer<T>> react(EventBus selfType,
                                                         String selector,
                                                         @DelegatesTo(strategy=1,value=ClosureEventConsumer.ReplyDecorator.class)
                                                         groovy.lang.Closure handler)

send

public static <T> EventBus send(EventBus selfType,
                                Object key,
                                T obj)

send

public static <T> EventBus send(EventBus selfType,
                                Object key,
                                T obj,
                                @DelegatesTo(strategy=1,value=ClosureEventConsumer.ReplyDecorator.class)
                                groovy.lang.Closure handler)

send

public static <T> EventBus send(EventBus selfType,
                                Object key,
                                Event<T> obj,
                                @DelegatesTo(strategy=1,value=ClosureEventConsumer.ReplyDecorator.class)
                                groovy.lang.Closure handler)

notify

public static <T> Bus notify(Bus selfType,
                             Object key,
                             T obj)

notify

public static <T> Bus notify(Bus selfType,
                             Object key,
                             Supplier<Event<T>> obj)

notify

public static Bus notify(Bus selfType,
                         Object key)

notify

public static <T> Bus notify(Bus selfType,
                             String key,
                             groovy.lang.Closure<T> closure)

notify

public static Bus notify(Bus selfType,
                         Map params)

call

public static <T,V> void call(Function<T,V> selfType,
                              T value)

call

public static <T> void call(Consumer<T> selfType,
                            T value)

call

public static <T> void call(Supplier<T> selfType)