Skip navigation links
A B C D E F G H I J L M N O P R S T U W Z 

A

a() - Method in class com.github.davidmoten.rx2.util.Pair
 
acceptSocketIf(Predicate<? super Socket>) - Method in class com.github.davidmoten.rx2.IO.ServerSocketBuilder
 
acceptTimeoutMs(int) - Method in class com.github.davidmoten.rx2.IO.ServerSocketBuilder
 
action(Consumer<? super RetryWhen.ErrorAndDuration>) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
action(Consumer<? super RetryWhen.ErrorAndDuration>) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
Actions - Class in com.github.davidmoten.rx2
 
add(String) - Method in class com.github.davidmoten.rx2.internal.flowable.DelimitedStringLinkedList
 
add(Number) - Method in class com.github.davidmoten.rx2.Statistics
 
addCalled() - Method in class com.github.davidmoten.rx2.internal.flowable.DelimitedStringLinkedList
 
addLongTo(List<Long>) - Static method in class com.github.davidmoten.rx2.Consumers
 
addTo(List<T>) - Static method in class com.github.davidmoten.rx2.Consumers
 
alwaysFalse() - Static method in class com.github.davidmoten.rx2.Predicates
 
alwaysTrue() - Static method in class com.github.davidmoten.rx2.Predicates
 
apply(Flowable<In>) - Method in class com.github.davidmoten.rx2.internal.flowable.TransformerStateMachine
 
apply(State, In, FlowableEmitter<Out>) - Method in interface com.github.davidmoten.rx2.StateMachine.Transition
 
assertBytesEquals(byte[]) - Static method in class com.github.davidmoten.rx2.Consumers
 
AssertionException - Exception in com.github.davidmoten.rx2.exceptions
 
AssertionException(String) - Constructor for exception com.github.davidmoten.rx2.exceptions.AssertionException
 
avail(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
avail() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 

B

b() - Method in class com.github.davidmoten.rx2.util.Pair
 
backpressureStrategy(BackpressureStrategy) - Method in class com.github.davidmoten.rx2.StateMachine.Builder3
 
BiFunctions - Class in com.github.davidmoten.rx2
 
blockUntilWorkFinished(Scheduler, int, long, TimeUnit) - Static method in class com.github.davidmoten.rx2.SchedulerHelper
 
blockUntilWorkFinished(Scheduler, int) - Static method in class com.github.davidmoten.rx2.SchedulerHelper
 
bufferSize(int) - Method in class com.github.davidmoten.rx2.IO.ServerSocketBuilder
 
build() - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
build() - Method in class com.github.davidmoten.rx2.StateMachine.Builder3
 
builder() - Static method in class com.github.davidmoten.rx2.StateMachine
 
builderFlowable() - Static method in class com.github.davidmoten.rx2.buffertofile.Options
 
builderObservable() - Static method in class com.github.davidmoten.rx2.buffertofile.Options
 
bytes() - Static method in class com.github.davidmoten.rx2.buffertofile.Serializers
 
Bytes - Class in com.github.davidmoten.rx2
 

C

Callables - Class in com.github.davidmoten.rx2
 
clear() - Method in class com.github.davidmoten.rx2.internal.flowable.DelimitedStringLinkedList
 
close() - Static method in class com.github.davidmoten.rx2.Consumers
 
close() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
close() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
close() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.PagedQueue
 
close() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
collect(Flowable<byte[]>) - Static method in class com.github.davidmoten.rx2.Bytes
 
collect() - Static method in class com.github.davidmoten.rx2.Bytes
 
collectStats() - Static method in class com.github.davidmoten.rx2.BiFunctions
 
collectStats() - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
collectStats(Function<? super T, ? extends R>) - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
com.github.davidmoten.rx2 - package com.github.davidmoten.rx2
 
com.github.davidmoten.rx2.buffertofile - package com.github.davidmoten.rx2.buffertofile
 
com.github.davidmoten.rx2.exceptions - package com.github.davidmoten.rx2.exceptions
 
com.github.davidmoten.rx2.internal - package com.github.davidmoten.rx2.internal
 
com.github.davidmoten.rx2.internal.flowable - package com.github.davidmoten.rx2.internal.flowable
 
com.github.davidmoten.rx2.internal.flowable.buffertofile - package com.github.davidmoten.rx2.internal.flowable.buffertofile
 
com.github.davidmoten.rx2.util - package com.github.davidmoten.rx2.util
 
completion(StateMachine.Completion<State, Out>) - Method in class com.github.davidmoten.rx2.StateMachine.Builder3
 
concat(Flowable<String>) - Static method in class com.github.davidmoten.rx2.Strings
 
concat(Flowable<String>, String) - Static method in class com.github.davidmoten.rx2.Strings
 
concat(String) - Static method in class com.github.davidmoten.rx2.Strings
 
concat() - Static method in class com.github.davidmoten.rx2.Strings
 
constant(T) - Static method in class com.github.davidmoten.rx2.Callables
 
constant(T) - Static method in class com.github.davidmoten.rx2.Functions
 
Consumers - Class in com.github.davidmoten.rx2
 
count() - Method in class com.github.davidmoten.rx2.Statistics
 
create(Callable<? extends ServerSocket>, int, int, Action, int, Predicate<? super Socket>) - Static method in class com.github.davidmoten.rx2.internal.flowable.FlowableServerSocket
 
create(Callable<? extends State>, Function3<? super State, ? super In, ? super FlowableEmitter<Out>, ? extends State>, BiPredicate<? super State, ? super FlowableEmitter<Out>>, BackpressureStrategy, int) - Static method in class com.github.davidmoten.rx2.internal.flowable.TransformerStateMachine
 
create() - Method in class com.github.davidmoten.rx2.IO.ServerSocketBuilder
 
create() - Static method in class com.github.davidmoten.rx2.Statistics
 
create(T, S) - Static method in class com.github.davidmoten.rx2.util.Pair
 
createWorker() - Method in class com.github.davidmoten.rx2.internal.SchedulerWithId
 

D

DataSerializer<T> - Interface in com.github.davidmoten.rx2.buffertofile
 
decode(CharsetDecoder, BackpressureStrategy, int) - Static method in class com.github.davidmoten.rx2.internal.flowable.TransformerDecode
 
decode(CharsetDecoder) - Static method in class com.github.davidmoten.rx2.Strings
 
decode(CharsetDecoder, BackpressureStrategy, int) - Static method in class com.github.davidmoten.rx2.Strings
 
decode(Flowable<byte[]>, CharsetDecoder) - Static method in class com.github.davidmoten.rx2.Strings
 
decode(Flowable<byte[]>, Charset) - Static method in class com.github.davidmoten.rx2.Strings
 
decode(Flowable<byte[]>, String) - Static method in class com.github.davidmoten.rx2.Strings
 
decrement(AtomicInteger) - Static method in class com.github.davidmoten.rx2.Consumers
 
DEFAULT_FILE_PREFIX - Static variable in class com.github.davidmoten.rx2.buffertofile.Options
 
delay(Long, TimeUnit) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
delay(long, TimeUnit) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
delays(Flowable<Long>, TimeUnit) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
delays(Flowable<Long>, TimeUnit) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
delaysInt(Flowable<Integer>, TimeUnit) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
delaysInt(Flowable<Integer>, TimeUnit) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
DelimitedStringLinkedList - Class in com.github.davidmoten.rx2.internal.flowable
Enables a forward-only iteration of string values split by a delimiter across a linked list of strings.
DelimitedStringLinkedList(String) - Constructor for class com.github.davidmoten.rx2.internal.flowable.DelimitedStringLinkedList
 
deserialize(DataInput) - Method in interface com.github.davidmoten.rx2.buffertofile.DataSerializer
 
deserialize(byte[]) - Method in interface com.github.davidmoten.rx2.buffertofile.Serializer
Returns a non-null instance of T from the byte array of length > 0.
deserialize(byte[]) - Method in class com.github.davidmoten.rx2.buffertofile.SerializerString
 
deserialize(byte[]) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.SerializerBytes
 
deserialize(byte[]) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.SerializerJavaIO
 
doNothing() - Static method in class com.github.davidmoten.rx2.Actions
 
doNothing() - Static method in class com.github.davidmoten.rx2.Consumers
 
doOnEmpty(Action) - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
durationMs() - Method in class com.github.davidmoten.rx2.RetryWhen.ErrorAndDuration
 

E

equals(Object) - Method in class com.github.davidmoten.rx2.util.Pair
 
ErrorAndDuration(Throwable, long) - Constructor for class com.github.davidmoten.rx2.RetryWhen.ErrorAndDuration
 
exponentialBackoff(long, TimeUnit, double) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
exponentialBackoff(long, TimeUnit) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
exponentialBackoff(long, TimeUnit, double) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
exponentialBackoff(long, TimeUnit) - Static method in class com.github.davidmoten.rx2.RetryWhen
 

F

failWhenInstanceOf(Class<? extends Throwable>...) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
failWhenInstanceOf(Class<? extends Throwable>...) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
fileFactory(Callable<File>) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderFlowable
Sets the file factory to be used by the queue storage mechanism.
fileFactory(Callable<File>) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable
Sets the file factory to be used by the queue storage mechanism.
fileFactory() - Method in class com.github.davidmoten.rx2.buffertofile.Options
 
FlowableDoOnEmpty<T> - Class in com.github.davidmoten.rx2.internal.flowable
Calls a consumer just before completion if the stream was empty.
FlowableDoOnEmpty(Publisher<T>, Action) - Constructor for class com.github.davidmoten.rx2.internal.flowable.FlowableDoOnEmpty
 
FlowableMapLast<T> - Class in com.github.davidmoten.rx2.internal.flowable
 
FlowableMapLast(Flowable<T>, Function<? super T, ? extends T>) - Constructor for class com.github.davidmoten.rx2.internal.flowable.FlowableMapLast
 
FlowableMatch<A,B,K,C> - Class in com.github.davidmoten.rx2.internal.flowable
 
FlowableMatch(Flowable<A>, Flowable<B>, Function<? super A, ? extends K>, Function<? super B, ? extends K>, BiFunction<? super A, ? super B, C>, long) - Constructor for class com.github.davidmoten.rx2.internal.flowable.FlowableMatch
 
FlowableOnBackpressureBufferToFile<T> - Class in com.github.davidmoten.rx2.internal.flowable.buffertofile
 
FlowableOnBackpressureBufferToFile(Flowable<T>, Observable<T>, Options, Serializer<T>) - Constructor for class com.github.davidmoten.rx2.internal.flowable.buffertofile.FlowableOnBackpressureBufferToFile
 
FlowableRepeat<T> - Class in com.github.davidmoten.rx2.internal.flowable
 
FlowableRepeat(T, long) - Constructor for class com.github.davidmoten.rx2.internal.flowable.FlowableRepeat
 
FlowableReverse - Class in com.github.davidmoten.rx2.internal.flowable
 
Flowables - Class in com.github.davidmoten.rx2
 
FlowableServerSocket - Class in com.github.davidmoten.rx2.internal.flowable
 
FlowableStringSplitSimple - Class in com.github.davidmoten.rx2.internal.flowable
 
FlowableStringSplitSimple(Flowable<String>, String) - Constructor for class com.github.davidmoten.rx2.internal.flowable.FlowableStringSplitSimple
 
FlowableTransformers - Class in com.github.davidmoten.rx2
 
from(DataSerializer<T>) - Static method in class com.github.davidmoten.rx2.buffertofile.Serializers
 
from(InputStream, int) - Static method in class com.github.davidmoten.rx2.Bytes
Returns an Flowable stream of byte arrays from the given InputStream between 1 and bufferSize bytes.
from(File) - Static method in class com.github.davidmoten.rx2.Bytes
 
from(File, int) - Static method in class com.github.davidmoten.rx2.Bytes
 
from(InputStream) - Static method in class com.github.davidmoten.rx2.Bytes
Returns an Flowable stream of byte arrays from the given InputStream of 8192 bytes.
from(Reader, int) - Static method in class com.github.davidmoten.rx2.Strings
 
from(Reader) - Static method in class com.github.davidmoten.rx2.Strings
 
from(InputStream) - Static method in class com.github.davidmoten.rx2.Strings
 
from(InputStream, Charset) - Static method in class com.github.davidmoten.rx2.Strings
 
from(InputStream, Charset, int) - Static method in class com.github.davidmoten.rx2.Strings
 
from(File) - Static method in class com.github.davidmoten.rx2.Strings
 
from(File, Charset) - Static method in class com.github.davidmoten.rx2.Strings
 
from(Callable<Reader>) - Static method in class com.github.davidmoten.rx2.Strings
 
fromClasspath(Class<?>, String, Charset) - Static method in class com.github.davidmoten.rx2.Strings
 
fromClasspath(String, Charset) - Static method in class com.github.davidmoten.rx2.Strings
 
fromClasspath(String) - Static method in class com.github.davidmoten.rx2.Strings
 
Functions - Class in com.github.davidmoten.rx2
 

G

get(byte[], int, int, int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
get(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
getByte(long) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
getByte(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
getByte() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
getBytes(long, byte[], long, long) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
getComment() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 
getCompressedSize() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 
getCrc() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 
getExtra() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 
getInputStream() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 
getInt(long) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
getInt(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
getInt() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
getIntVolatile(long) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
getIntVolatile(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
getIntVolatile() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
getMethod() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 
getName() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 
getSize() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 
getTime() - Method in class com.github.davidmoten.rx2.util.ZippedEntry
 

H

hashCode() - Method in class com.github.davidmoten.rx2.util.Pair
 

I

identity() - Static method in class com.github.davidmoten.rx2.Functions
 
increment(AtomicInteger) - Static method in class com.github.davidmoten.rx2.Consumers
 
initialState(State) - Method in class com.github.davidmoten.rx2.StateMachine.Builder
 
initialStateFactory(Callable<State>) - Method in class com.github.davidmoten.rx2.StateMachine.Builder
 
IO - Class in com.github.davidmoten.rx2
 
IO.ServerSocketBuilder - Class in com.github.davidmoten.rx2
 

J

javaIO() - Static method in class com.github.davidmoten.rx2.buffertofile.Serializers
 
join(Flowable<String>) - Static method in class com.github.davidmoten.rx2.Strings
 
join(Flowable<String>, String) - Static method in class com.github.davidmoten.rx2.Strings
 
join(String) - Static method in class com.github.davidmoten.rx2.Strings
 
join() - Static method in class com.github.davidmoten.rx2.Strings
 

L

left() - Method in class com.github.davidmoten.rx2.util.Pair
 
length() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 

M

mapLast(Function<? super T, ? extends T>) - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
markForRewriteAndAdvance4Bytes() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
match(Flowable<A>, Flowable<B>, Function<? super A, K>, Function<? super B, K>, BiFunction<? super A, ? super B, C>, int) - Static method in class com.github.davidmoten.rx2.Flowables
 
match(Flowable<A>, Flowable<B>, Function<? super A, K>, Function<? super B, K>, BiFunction<? super A, ? super B, C>) - Static method in class com.github.davidmoten.rx2.Flowables
 
match(Flowable<A>, Flowable<B>, Function<? super A, K>, Function<? super B, K>, BiFunction<? super A, ? super B, C>, int) - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
matchWith(Flowable<B>, Function<? super A, K>, Function<? super B, K>, BiFunction<? super A, ? super B, C>, int) - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
matchWith(Flowable<B>, Function<? super A, K>, Function<? super B, K>, BiFunction<? super A, ? super B, C>) - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
maxRetries(int) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
maxRetries(int) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
mean() - Method in class com.github.davidmoten.rx2.Statistics
 
MemoryMappedFile - Class in com.github.davidmoten.rx2.internal.flowable.buffertofile
 
MemoryMappedFile(File, long) - Constructor for class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
moveReadPosition(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
moveWritePosition(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 

N

next() - Method in class com.github.davidmoten.rx2.internal.flowable.DelimitedStringLinkedList
 

O

ObservableTransformers - Class in com.github.davidmoten.rx2
 
offer(byte[]) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.PagedQueue
 
onBackpressureBufferToFile() - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
onBackpressureBufferToFile() - Static method in class com.github.davidmoten.rx2.ObservableTransformers
 
Options - Class in com.github.davidmoten.rx2.buffertofile
 
Options.BuilderFlowable - Class in com.github.davidmoten.rx2.buffertofile
 
Options.BuilderObservable - Class in com.github.davidmoten.rx2.buffertofile
 

P

Page - Class in com.github.davidmoten.rx2.internal.flowable.buffertofile
 
Page(File, int) - Constructor for class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
PagedQueue - Class in com.github.davidmoten.rx2.internal.flowable.buffertofile
 
PagedQueue(Callable<File>, int) - Constructor for class com.github.davidmoten.rx2.internal.flowable.buffertofile.PagedQueue
 
Pages - Class in com.github.davidmoten.rx2.internal.flowable.buffertofile
 
Pages(Callable<File>, int) - Constructor for class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
pageSizeBytes(int) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderFlowable
Sets the page size in bytes.
pageSizeBytes(int) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable
Sets the page size in bytes.
pageSizeBytes() - Method in class com.github.davidmoten.rx2.buffertofile.Options
 
Pair<T,S> - Class in com.github.davidmoten.rx2.util
 
Pair(T, S) - Constructor for class com.github.davidmoten.rx2.util.Pair
 
poll() - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.PagedQueue
 
preAcceptAction(Action) - Method in class com.github.davidmoten.rx2.IO.ServerSocketBuilder
 
Predicates - Class in com.github.davidmoten.rx2
 
println() - Static method in class com.github.davidmoten.rx2.Consumers
 
printStackTrace() - Static method in class com.github.davidmoten.rx2.Consumers
 
process(byte[], ByteBuffer, boolean, CharsetDecoder, FlowableEmitter<String>) - Static method in class com.github.davidmoten.rx2.internal.flowable.TransformerDecode
 
put(int, byte[], int, int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
put(byte[], int, int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
putByte(long, byte) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
putByte(int, byte) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
putByte(byte) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
putBytes(long, byte[], long, long) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
putInt(long, int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 
putInt(int, int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
putInt(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
putIntOrdered(int, int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Page
 
putIntOrderedAtRewriteMark(int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.Pages
 
putOrderedInt(long, int) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.MemoryMappedFile
 

R

readTimeoutMs(int) - Method in class com.github.davidmoten.rx2.IO.ServerSocketBuilder
 
remaining() - Method in class com.github.davidmoten.rx2.internal.flowable.DelimitedStringLinkedList
 
repeat(T) - Static method in class com.github.davidmoten.rx2.Flowables
 
repeat(T, long) - Static method in class com.github.davidmoten.rx2.Flowables
 
requestBatchSize(int) - Method in class com.github.davidmoten.rx2.StateMachine.Builder3
 
retryIf(Predicate<Throwable>) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
retryIf(Predicate<Throwable>) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
RetryWhen - Class in com.github.davidmoten.rx2
Provides builder for the Function parameter of Flowable.retryWhen(Function).
RetryWhen.Builder - Class in com.github.davidmoten.rx2
 
RetryWhen.ErrorAndDuration - Class in com.github.davidmoten.rx2
 
retryWhenInstanceOf(Class<? extends Throwable>...) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
retryWhenInstanceOf(Class<? extends Throwable>...) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
reverse() - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
reverse(Flowable<T>) - Static method in class com.github.davidmoten.rx2.internal.flowable.FlowableReverse
 
right() - Method in class com.github.davidmoten.rx2.util.Pair
 

S

scheduler(Scheduler) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderFlowable
Sets the scheduler to use for reading items from files and emitting them.
scheduler(Scheduler) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable
Sets the scheduler to use for reading items from files and emitting them.
scheduler() - Method in class com.github.davidmoten.rx2.buffertofile.Options
 
scheduler(Scheduler) - Method in class com.github.davidmoten.rx2.RetryWhen.Builder
 
scheduler(Scheduler) - Static method in class com.github.davidmoten.rx2.RetryWhen
 
SchedulerHelper - Class in com.github.davidmoten.rx2
 
SchedulerWithId - Class in com.github.davidmoten.rx2.internal
 
SchedulerWithId(Scheduler, String) - Constructor for class com.github.davidmoten.rx2.internal.SchedulerWithId
 
sd() - Method in class com.github.davidmoten.rx2.Statistics
 
serialize(T, DataOutput) - Method in interface com.github.davidmoten.rx2.buffertofile.DataSerializer
 
serialize(T) - Method in interface com.github.davidmoten.rx2.buffertofile.Serializer
Returns a byte array of length > 0 that is the serialization of the given value.
serialize(String) - Method in class com.github.davidmoten.rx2.buffertofile.SerializerString
 
serialize(byte[]) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.SerializerBytes
 
serialize(Serializable) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.SerializerJavaIO
 
serializer(Serializer<T>) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderFlowable
 
serializer(DataSerializer<T>) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderFlowable
 
serializer(Serializer<T>) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable
 
serializer(DataSerializer<T>) - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable
 
Serializer<T> - Interface in com.github.davidmoten.rx2.buffertofile
 
serializerBytes() - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderFlowable
Returns a Flowable Transformer that buffers items to disk (files).
serializerBytes() - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable
Returns a Flowable Transformer that buffers items to disk (files).
SerializerBytes - Class in com.github.davidmoten.rx2.internal.flowable.buffertofile
 
SerializerBytes() - Constructor for class com.github.davidmoten.rx2.internal.flowable.buffertofile.SerializerBytes
 
serializerJavaIO() - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderFlowable
Returns a Flowable Transformer to buffer stream items to disk (files).
serializerJavaIO() - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable
Returns a Flowable Transformer to buffer stream items to disk (files).
SerializerJavaIO<T extends Serializable> - Class in com.github.davidmoten.rx2.internal.flowable.buffertofile
 
SerializerJavaIO() - Constructor for class com.github.davidmoten.rx2.internal.flowable.buffertofile.SerializerJavaIO
 
Serializers - Class in com.github.davidmoten.rx2.buffertofile
 
SerializerString - Class in com.github.davidmoten.rx2.buffertofile
 
SerializerString(Charset) - Constructor for class com.github.davidmoten.rx2.buffertofile.SerializerString
 
serializerUtf8() - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderFlowable
 
serializerUtf8() - Method in class com.github.davidmoten.rx2.buffertofile.Options.BuilderObservable
 
serverSocket(int) - Static method in class com.github.davidmoten.rx2.IO
 
serverSocket(Callable<? extends ServerSocket>) - Static method in class com.github.davidmoten.rx2.IO
 
serverSocketAutoAllocatePort(Consumer<Integer>) - Static method in class com.github.davidmoten.rx2.IO
 
ServerSocketBuilder(Callable<? extends ServerSocket>) - Constructor for class com.github.davidmoten.rx2.IO.ServerSocketBuilder
 
set(AtomicReference<T>) - Static method in class com.github.davidmoten.rx2.Consumers
 
set(AtomicInteger) - Static method in class com.github.davidmoten.rx2.Consumers
 
setToTrue(AtomicBoolean) - Static method in class com.github.davidmoten.rx2.Actions
 
setToTrue(AtomicBoolean) - Static method in class com.github.davidmoten.rx2.Consumers
 
sizeHint() - Method in interface com.github.davidmoten.rx2.buffertofile.DataSerializer
Returns 0 to indicate unknown (unbounded) capacity.
split(String, Pattern, BackpressureStrategy, int) - Static method in class com.github.davidmoten.rx2.internal.flowable.TransformerStringSplit
 
split(Flowable<String>, String) - Static method in class com.github.davidmoten.rx2.Strings
 
split(String) - Static method in class com.github.davidmoten.rx2.Strings
 
split(Pattern) - Static method in class com.github.davidmoten.rx2.Strings
 
split(String, BackpressureStrategy, int) - Static method in class com.github.davidmoten.rx2.Strings
 
split(Pattern, BackpressureStrategy, int) - Static method in class com.github.davidmoten.rx2.Strings
 
splitLinesSkipComments(InputStream, Charset, String, String) - Static method in class com.github.davidmoten.rx2.Strings
 
splitSimple(String) - Static method in class com.github.davidmoten.rx2.Strings
Splits on a string delimiter, not a pattern.
stateMachine(Callable<? extends State>, Function3<? super State, ? super In, ? super FlowableEmitter<Out>, ? extends State>, BiPredicate<? super State, ? super FlowableEmitter<Out>>, BackpressureStrategy, int) - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
stateMachine() - Static method in class com.github.davidmoten.rx2.FlowableTransformers
 
StateMachine - Class in com.github.davidmoten.rx2
 
StateMachine.Builder - Class in com.github.davidmoten.rx2
 
StateMachine.Builder2<State> - Class in com.github.davidmoten.rx2
 
StateMachine.Builder3<State,In,Out> - Class in com.github.davidmoten.rx2
 
StateMachine.Completion<State,Out> - Interface in com.github.davidmoten.rx2
 
StateMachine.Transition<State,In,Out> - Interface in com.github.davidmoten.rx2
 
Statistics - Class in com.github.davidmoten.rx2
 
string(Charset) - Static method in class com.github.davidmoten.rx2.buffertofile.Serializers
 
Strings - Class in com.github.davidmoten.rx2
 
strings(Flowable<?>) - Static method in class com.github.davidmoten.rx2.Strings
 
strings() - Static method in class com.github.davidmoten.rx2.Strings
 
subscribeActual(Subscriber<? super T>) - Method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.FlowableOnBackpressureBufferToFile
 
subscribeActual(Subscriber<? super T>) - Method in class com.github.davidmoten.rx2.internal.flowable.FlowableDoOnEmpty
 
subscribeActual(Subscriber<? super T>) - Method in class com.github.davidmoten.rx2.internal.flowable.FlowableMapLast
 
subscribeActual(Subscriber<? super C>) - Method in class com.github.davidmoten.rx2.internal.flowable.FlowableMatch
 
subscribeActual(Subscriber<? super T>) - Method in class com.github.davidmoten.rx2.internal.flowable.FlowableRepeat
 
subscribeActual(Subscriber<? super String>) - Method in class com.github.davidmoten.rx2.internal.flowable.FlowableStringSplitSimple
 
sum() - Method in class com.github.davidmoten.rx2.Statistics
 
sumSquares() - Method in class com.github.davidmoten.rx2.Statistics
 

T

test(State, FlowableEmitter<Out>) - Method in interface com.github.davidmoten.rx2.StateMachine.Completion
 
throwable() - Method in class com.github.davidmoten.rx2.RetryWhen.ErrorAndDuration
 
throwing(Exception) - Static method in class com.github.davidmoten.rx2.Actions
 
throwing() - Static method in class com.github.davidmoten.rx2.BiFunctions
 
throwing() - Static method in class com.github.davidmoten.rx2.Functions
 
ThrowingException - Exception in com.github.davidmoten.rx2.exceptions
 
ThrowingException() - Constructor for exception com.github.davidmoten.rx2.exceptions.ThrowingException
 
toString() - Method in class com.github.davidmoten.rx2.Statistics
 
toString() - Method in class com.github.davidmoten.rx2.util.Pair
 
TransformerDecode - Class in com.github.davidmoten.rx2.internal.flowable
 
TransformerStateMachine<State,In,Out> - Class in com.github.davidmoten.rx2.internal.flowable
 
TransformerStringSplit - Class in com.github.davidmoten.rx2.internal.flowable
 
transition(StateMachine.Transition<State, In, Out>) - Method in class com.github.davidmoten.rx2.StateMachine.Builder2
 
trim() - Static method in class com.github.davidmoten.rx2.Strings
 

U

unsafe() - Static method in class com.github.davidmoten.rx2.internal.flowable.buffertofile.UnsafeAccess
 
UnsafeAccess - Class in com.github.davidmoten.rx2.internal.flowable.buffertofile
 
unzip(File) - Static method in class com.github.davidmoten.rx2.Bytes
 
unzip(InputStream) - Static method in class com.github.davidmoten.rx2.Bytes
 
unzip(ZipInputStream) - Static method in class com.github.davidmoten.rx2.Bytes
 
utf8() - Static method in class com.github.davidmoten.rx2.buffertofile.Serializers
 
UTF_8 - Static variable in class com.github.davidmoten.rx2.Strings
 

W

withThreadId(Scheduler, String) - Static method in class com.github.davidmoten.rx2.SchedulerHelper
 
withThreadIdFromCallSite(Scheduler) - Static method in class com.github.davidmoten.rx2.SchedulerHelper
 

Z

ZippedEntry - Class in com.github.davidmoten.rx2.util
 
ZippedEntry(ZipEntry, InputStream) - Constructor for class com.github.davidmoten.rx2.util.ZippedEntry
 
A B C D E F G H I J L M N O P R S T U W Z 
Skip navigation links

Copyright © 2013–2017. All rights reserved.