C E F G I J P R S

C

clear() - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

Clear all registered adapters & pipes from the registry

com.aol.micro.server.javaslang - package com.aol.micro.server.javaslang

com.aol.micro.server.javaslang.reactive - package com.aol.micro.server.javaslang.reactive

cpuFutureStream(K) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Get a LazyFutureStream optimized for CPU operations, connected to the adapter cached in JavaslangPipes with the specified key

cpuStreamBuilder() - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

E

enqueue(K, V) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Add a value to an simple-react Async.Queue

F

futureStreamCPUBound(Object) - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

futureStreamIOBound(Object) - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

G

get(K) - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

I

ioFutureStream(K) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Get a LazyFutureStream optimized for IO operations, connected to the adapter cached in JavaslangPipes with the specified key

ioStreamBuilder() - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

J

jacksonModules() - Method in class com.aol.micro.server.javaslang.JavaslangPlugin

JavaslangPipes - Class in com.aol.micro.server.javaslang.reactive

Store for Pipes for cross-thread communication

JavaslangPipes() - Constructor for class com.aol.micro.server.javaslang.reactive.JavaslangPipes

JavaslangPlugin - Class in com.aol.micro.server.javaslang

Collections of Spring configuration classes (Classes annotated with @Configuration) that configure various useful pieces of functionality - such as property file loading, datasources, scheduling etc

JavaslangPlugin() - Constructor for class com.aol.micro.server.javaslang.JavaslangPlugin

JavaslangReactive - Interface in com.aol.micro.server.javaslang.reactive

Mixin / Trait for Reactive behaviour via simple-react

P

publish(Publisher<T>) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Publish a reactive-streams publisher to a new Javaslang Stream

R

register(K, Adapter<V>) - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

Register specified adapter with key

registerForCPU(Object, Adapter<V>) - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

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

registerForIO(Object, Adapter<V>) - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

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

registerFroSequential(Object, Adapter<V>) - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

Register a Queue, and get back a listening SequenceM

S

sequentialStream(K) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Get a Javaslang Stream connected to the adapter cached in JavaslangPipes with the specified key

stream(Object) - Static method in class com.aol.micro.server.javaslang.reactive.JavaslangPipes

subsribe(Stream<T>, Subscriber<T>) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Have a reactive-stream subscriber subscribe to a Javaslang Stream.

subsribe(Stream<T>, Subscriber<T>, Executor) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Have a reactive-stream subscriber subscribe to a Javaslang Stream asynchronously.

switchToCPU(LazyFutureStream<T>) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Switch LazyFutureStream into execution mode suitable for CPU bound execution (reuse cpuReactors task executor)

switchToIO(LazyFutureStream<T>) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Switch LazyFutureStream into execution mode suitable for IO (reuse ioReactors task executor)

switchToSequential(LazyFutureStream<T>) - Method in interface com.aol.micro.server.javaslang.reactive.JavaslangReactive

Switch a LazyFutureStream to a Javaslang Stream

C E F G I J P R S