com.aol.micro.server.javaslang.reactive

Class JavaslangPipes

java.lang.Object

com.aol.micro.server.javaslang.reactive.JavaslangPipes

public class JavaslangPipes
extends java.lang.Object

Store for Pipes for cross-thread communication

Constructor Summary

Constructors

Constructor and Description
JavaslangPipes()

Method Summary

Modifier and Type	Method and Description
static void	clear() Clear all registered adapters & pipes from the registry
static <V> com.aol.simple.react.stream.traits.LazyFutureStream<V>	futureStreamCPUBound(java.lang.Object key)
static <V> com.aol.simple.react.stream.traits.LazyFutureStream<V>	futureStreamIOBound(java.lang.Object key)
static <K,V> java.util.Optional<com.aol.simple.react.async.Adapter<V>>	get(K key)
static <K,V> void	register(K key, com.aol.simple.react.async.Adapter<V> adapter) Register specified adapter with key
static <V> com.aol.simple.react.stream.traits.LazyFutureStream<V>	registerForCPU(java.lang.Object key, com.aol.simple.react.async.Adapter<V> adapter) Register a Queue, and get back a listening LazyFutureStream optimized for CPU Bound operations
static <V> com.aol.simple.react.stream.traits.LazyFutureStream<V>	registerForIO(java.lang.Object key, com.aol.simple.react.async.Adapter<V> adapter) Register a Queue, and get back a listening LazyFutureStream optimized for IO Bound operations
static <V> javaslang.collection.Stream<V>	registerFroSequential(java.lang.Object key, com.aol.simple.react.async.Adapter<V> adapter) Register a Queue, and get back a listening SequenceM
static <V> javaslang.collection.Stream<V>	stream(java.lang.Object key)

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaslangPipes

public JavaslangPipes()

Method Detail

get

public static <K,V> java.util.Optional<com.aol.simple.react.async.Adapter<V>> get(K key)

Parameters:

key - : Adapter identifier

Returns:

selected Queue

registerFroSequential

public static <V> javaslang.collection.Stream<V> registerFroSequential(java.lang.Object key,
                                                                       com.aol.simple.react.async.Adapter<V> adapter)

Register a Queue, and get back a listening SequenceM

 
 Stream<String> stream = JavaslangPipes.registerForSequential("test", QueueFactories.
											<String>boundedNonBlockingQueue(100)
												.build());
		stream.filter(it->it!=null)
		      .peek(this::process)
		      .forEach(System.out::println);
 
   //note that the take operator will limit items taken, but not close connection to the queue / adapter
   //queue needs to be closed independently

 

Parameters:

key - : Adapter identifier

adapter -

Returns:

LazyFutureStream from supplied Queue, optimisied for CPU bound operation

registerForCPU

public static <V> com.aol.simple.react.stream.traits.LazyFutureStream<V> registerForCPU(java.lang.Object key,
                                                                                        com.aol.simple.react.async.Adapter<V> adapter)

Register a Queue, and get back a listening LazyFutureStream optimized for CPU Bound operations

 
 LazyFutureStream<String> stream = JavaslangPipes.registerForCPU("test", QueueFactories.
											<String>boundedNonBlockingQueue(100)
												.build());
		stream.filter(it->it!=null)
		      .peek(this::process)
		      .forEach(System.out::println);
 
 

Parameters:

key - : Adapter identifier

adapter -

Returns:

LazyFutureStream from supplied Queue, optimisied for CPU bound operation

registerForIO

public static <V> com.aol.simple.react.stream.traits.LazyFutureStream<V> registerForIO(java.lang.Object key,
                                                                                       com.aol.simple.react.async.Adapter<V> adapter)

Register a Queue, and get back a listening LazyFutureStream optimized for IO Bound operations

 
 LazyFutureStream<String> stream = JavaslangPipes.registerForIO("test", QueueFactories.
											<String>boundedNonBlockingQueue(100)
												.build());
		stream.filter(it->it!=null)
		      .peek(this::load)
		      .run(System.out::println);
 
 

Parameters:

key - : Adapter identifier

adapter -

Returns:

LazyFutureStream from supplied Queue

stream

public static <V> javaslang.collection.Stream<V> stream(java.lang.Object key)

Parameters:

key - : Queue identifier

Returns:

LazyFutureStream that reads from specified Queue

futureStreamIOBound

public static <V> com.aol.simple.react.stream.traits.LazyFutureStream<V> futureStreamIOBound(java.lang.Object key)

Parameters:

key - : Queue identifier

Returns:

LazyFutureStream that reads from specified Queue

futureStreamCPUBound

public static <V> com.aol.simple.react.stream.traits.LazyFutureStream<V> futureStreamCPUBound(java.lang.Object key)

Parameters:

key - : Queue identifier

Returns:

LazyFutureStream that reads from specified Queue

clear

public static void clear()

Clear all registered adapters & pipes from the registry

register

public static <K,V> void register(K key,
                                  com.aol.simple.react.async.Adapter<V> adapter)

Register specified adapter with key

Parameters:

key - Lookup key for adapter

adapter - Adapter to register