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