io.apptik.roxy

Class ReactorProxies

java.lang.Object

io.apptik.roxy.ReactorProxies

public final class ReactorProxies
extends java.lang.Object

Helper Roxy factories for common proxies based on Reactor-Core

Method Summary

Modifier and Type	Method and Description
static ReactorProcProxy	behaviorProcessorProxy()
static ReactorProcProxy	emitterProcessorProxy()
static ReactorProcProxy	replayProcessorProxy()
static ReactorProcProxy	safeBehaviorProcessorProxy()
static ReactorProcProxy	safeEmitterProcessorProxy()
static ReactorProcProxy	safeReplayProcessorProxy()
static ReactorProcProxy	safeSerializedBehaviorProcessorProxy()
static ReactorProcProxy	safeSerializedEmitterProcessorProxy()
static ReactorProcProxy	safeSerializedReplayProcessorProxy()
static ReactorProcProxy	safeSerializedTopicProcessorProxy()
static ReactorProcProxy	safeSerializedWorkQueueProcessorProxy()
static ReactorProcProxy	safeTopicProcessorProxy()
static ReactorProcProxy	safeWorkQueueProcessorProxy()
static ReactorProcProxy	serializedBehaviorProcessorProxy()
static ReactorProcProxy	serializedEmitterProcessorProxy()
static ReactorProcProxy	serializedReplayProcessorProxy()
static ReactorProcProxy	serializedTopicProcessorProxy()
static ReactorProcProxy	serializedWorkQueueProcessorProxy()
static ReactorProcProxy	topicProcessorProxy()
static ReactorProcProxy	workQueueProcessorProxy()

Methods inherited from class java.lang.Object

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

Method Detail

behaviorProcessorProxy

public static ReactorProcProxy behaviorProcessorProxy()

serializedBehaviorProcessorProxy

public static ReactorProcProxy serializedBehaviorProcessorProxy()

emitterProcessorProxy

public static ReactorProcProxy emitterProcessorProxy()

serializedEmitterProcessorProxy

public static ReactorProcProxy serializedEmitterProcessorProxy()

topicProcessorProxy

public static ReactorProcProxy topicProcessorProxy()

serializedTopicProcessorProxy

public static ReactorProcProxy serializedTopicProcessorProxy()

replayProcessorProxy

public static ReactorProcProxy replayProcessorProxy()

serializedReplayProcessorProxy

public static ReactorProcProxy serializedReplayProcessorProxy()

workQueueProcessorProxy

public static ReactorProcProxy workQueueProcessorProxy()

serializedWorkQueueProcessorProxy

public static ReactorProcProxy serializedWorkQueueProcessorProxy()

safeBehaviorProcessorProxy

public static ReactorProcProxy safeBehaviorProcessorProxy()

safeSerializedBehaviorProcessorProxy

public static ReactorProcProxy safeSerializedBehaviorProcessorProxy()

safeEmitterProcessorProxy

public static ReactorProcProxy safeEmitterProcessorProxy()

safeSerializedEmitterProcessorProxy

public static ReactorProcProxy safeSerializedEmitterProcessorProxy()

safeTopicProcessorProxy

public static ReactorProcProxy safeTopicProcessorProxy()

safeSerializedTopicProcessorProxy

public static ReactorProcProxy safeSerializedTopicProcessorProxy()

safeReplayProcessorProxy

public static ReactorProcProxy safeReplayProcessorProxy()

safeSerializedReplayProcessorProxy

public static ReactorProcProxy safeSerializedReplayProcessorProxy()

safeWorkQueueProcessorProxy

public static ReactorProcProxy safeWorkQueueProcessorProxy()

safeSerializedWorkQueueProcessorProxy

public static ReactorProcProxy safeSerializedWorkQueueProcessorProxy()