A B C D F G H I J M N O P R S T U V W

A

AfterOnNext - Interface in org.davidmoten.rx2.io.internal

afterOnNextFactory() - Method in class org.davidmoten.rx2.http.Response

AfterOnNextFactory - Interface in org.davidmoten.rx2.io.internal

asByteBuffer() - Method in class org.davidmoten.rx2.io.internal.NoCopyByteArrayOutputStream

async() - Method in class org.davidmoten.rx2.http.Response.Builder

async(boolean) - Method in class org.davidmoten.rx2.http.Response.Builder

autoFlush() - Method in class org.davidmoten.rx2.http.Response.Builder

Don'f flush after onNext emissions.

available() - Method in class org.davidmoten.rx2.io.internal.ByteBufferInputStream

B

basicAuth(String, String) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the Basic Authentication details for all HTTP connections (subscription, request and cancellation).

buffer() - Method in class org.davidmoten.rx2.io.internal.NoCopyByteArrayOutputStream

build() - Method in class org.davidmoten.rx2.http.Response.Builder

build() - Method in class org.davidmoten.rx2.io.Client.Builder

Returns the built Flowable<ByteBuffer> based on all the builder options specified.

ByteBufferInputStream - Class in org.davidmoten.rx2.io.internal

ByteBufferInputStream(ByteBuffer) - Constructor for class org.davidmoten.rx2.io.internal.ByteBufferInputStream

C

Client - Class in org.davidmoten.rx2.io

Client.Builder - Class in org.davidmoten.rx2.io

close() - Method in interface org.davidmoten.rx2.http.Writer

close() - Method in class org.davidmoten.rx2.io.internal.ServletHandler

close(Closeable) - Static method in class org.davidmoten.rx2.io.internal.Util

connectTimeoutMs(int) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the connect timeout in ms for the HTTP connection.

create() - Method in interface org.davidmoten.rx2.io.internal.AfterOnNextFactory

create() - Static method in class org.davidmoten.rx2.io.internal.ServletHandler

createDefault(OutputStream) - Static method in interface org.davidmoten.rx2.http.Writer

createWriter(OutputStream) - Method in interface org.davidmoten.rx2.http.WriterFactory

D

DEFAULT - Static variable in interface org.davidmoten.rx2.http.WriterFactory

DEFAULT - Static variable in interface org.davidmoten.rx2.io.internal.AfterOnNextFactory

DefaultSerializer<T extends Serializable> - Class in org.davidmoten.rx2.io.internal

DefaultSerializer(int) - Constructor for class org.davidmoten.rx2.io.internal.DefaultSerializer

defaultWriter() - Static method in class org.davidmoten.rx2.io.internal.Util

deserialize(ByteBuffer) - Method in interface org.davidmoten.rx2.io.Deserializer

deserialize(ByteBuffer) - Method in class org.davidmoten.rx2.io.internal.DefaultSerializer

deserialized() - Method in class org.davidmoten.rx2.io.Client.Builder

Returns the Flowable where deserialization is performed by Serializer.javaIo().

deserializer(Deserializer<T>) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the deserializer to be used on the arriving ByteBuffers.

Deserializer<T> - Interface in org.davidmoten.rx2.io

destroy() - Method in class org.davidmoten.rx2.http.FlowableHttpServlet

doGet(HttpServletRequest, HttpServletResponse) - Method in class org.davidmoten.rx2.http.FlowableHttpServlet

doGet(Callable<Response>, HttpServletRequest, HttpServletResponse) - Method in class org.davidmoten.rx2.io.internal.ServletHandler

doPost(HttpServletRequest, HttpServletResponse) - Method in class org.davidmoten.rx2.http.FlowableHttpServlet

F

FlowableFromInputStream - Class in org.davidmoten.rx2.io.internal

FlowableFromInputStream(InputStream, BiConsumer<Long, Long>) - Constructor for class org.davidmoten.rx2.io.internal.FlowableFromInputStream

FlowableHttpServlet - Class in org.davidmoten.rx2.http

FlowableHttpServlet() - Constructor for class org.davidmoten.rx2.http.FlowableHttpServlet

FlowableSingleFlatMapPublisher<S,T> - Class in org.davidmoten.rx2.io.internal

FlowableSingleFlatMapPublisher(SingleSource<S>, Function<? super S, ? extends Flowable<? extends T>>) - Constructor for class org.davidmoten.rx2.io.internal.FlowableSingleFlatMapPublisher

flush() - Method in interface org.davidmoten.rx2.http.Writer

flushAfter(int, int) - Static method in interface org.davidmoten.rx2.io.internal.AfterOnNextFactory

flushAfterBytes(int) - Method in class org.davidmoten.rx2.http.Response.Builder

flushAfterItems(int) - Method in class org.davidmoten.rx2.http.Response.Builder

flushRequested(int) - Method in interface org.davidmoten.rx2.io.internal.AfterOnNext

from(Publisher<? extends ByteBuffer>) - Static method in class org.davidmoten.rx2.http.Response

G

get(String) - Static method in class org.davidmoten.rx2.io.Client

Returns a Builder for an over-network Flowable.

H

handle(Publisher<? extends ByteBuffer>, SingleSource<OutputStream>, Runnable, long, Scheduler, Consumer<Subscription>, WriterFactory, AfterOnNextFactory) - Static method in class org.davidmoten.rx2.io.internal.Server

HttpMethod - Enum in org.davidmoten.rx2.io.internal

I

init(ServletConfig) - Method in class org.davidmoten.rx2.http.FlowableHttpServlet

instance() - Static method in class org.davidmoten.rx2.io.internal.DefaultSerializer

isAsync() - Method in class org.davidmoten.rx2.http.Response

J

javaIo() - Static method in interface org.davidmoten.rx2.io.Serializer

M

method() - Method in enum org.davidmoten.rx2.io.internal.HttpMethod

N

NoCopyByteArrayOutputStream - Class in org.davidmoten.rx2.io.internal

NoCopyByteArrayOutputStream(int) - Constructor for class org.davidmoten.rx2.io.internal.NoCopyByteArrayOutputStream

O

org.davidmoten.rx2.http - package org.davidmoten.rx2.http

org.davidmoten.rx2.io - package org.davidmoten.rx2.io

org.davidmoten.rx2.io.internal - package org.davidmoten.rx2.io.internal

P

post(String) - Static method in class org.davidmoten.rx2.io.Client

Returns a Builder for an over-network Flowable.

proxy(String, int) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the proxy details for the HTTP connection.

proxy(Proxy) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the proxy for the HTTP connection.

publisher() - Method in class org.davidmoten.rx2.http.Response

publisher(Publisher<? extends ByteBuffer>) - Static method in class org.davidmoten.rx2.http.Response

R

read(Single<InputStream>, BiConsumer<Long, Long>) - Static method in class org.davidmoten.rx2.io.Client

read() - Method in class org.davidmoten.rx2.io.internal.ByteBufferInputStream

read(byte[], int, int) - Method in class org.davidmoten.rx2.io.internal.ByteBufferInputStream

readFully(InputStream, byte[], int, int) - Static method in class org.davidmoten.rx2.io.internal.Util

readInt(InputStream) - Static method in class org.davidmoten.rx2.io.internal.Util

readLong(InputStream) - Static method in class org.davidmoten.rx2.io.internal.Util

readTimeoutMs(int) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the read timeout in ms for the HTTP connection.

requestHeader(String, String) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets a request header for the HTTP connection.

requestScheduler(Scheduler) - Method in class org.davidmoten.rx2.http.Response.Builder

requestScheduler() - Method in class org.davidmoten.rx2.http.Response

requestScheduler(Scheduler) - Method in class org.davidmoten.rx2.io.Client.Builder

respond(HttpServletRequest) - Method in class org.davidmoten.rx2.http.FlowableHttpServlet

Response - Class in org.davidmoten.rx2.http

Response.Builder - Class in org.davidmoten.rx2.http

S

serialize(T) - Method in class org.davidmoten.rx2.io.internal.DefaultSerializer

serialize(T) - Method in interface org.davidmoten.rx2.io.Serializer

Serializer<T> - Interface in org.davidmoten.rx2.io

SerializerDeserializer<T> - Interface in org.davidmoten.rx2.io

Server - Class in org.davidmoten.rx2.io.internal

ServletHandler - Class in org.davidmoten.rx2.io.internal

sslContext(SSLContext) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the SSLContext to be used for HTTP connections.

sslSocketFactory(SSLSocketFactory) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the SSLSocketFactory to be used for HTTPS connections.

subscribeActual(Subscriber<? super ByteBuffer>) - Method in class org.davidmoten.rx2.io.internal.FlowableFromInputStream

subscribeActual(Subscriber<? super T>) - Method in class org.davidmoten.rx2.io.internal.FlowableSingleFlatMapPublisher

T

toBytes(long) - Static method in class org.davidmoten.rx2.io.internal.Util

toBytes(int) - Static method in class org.davidmoten.rx2.io.internal.Util

toBytes(ByteBuffer) - Static method in class org.davidmoten.rx2.io.internal.Util

toLong(byte[]) - Static method in class org.davidmoten.rx2.io.internal.Util

transform(Consumer<HttpURLConnection>) - Method in class org.davidmoten.rx2.io.Client.Builder

Sets the actions that should be applied to HttpURLConnection before calling HttpURLConnection.getInputStream().

U

Util - Class in org.davidmoten.rx2.io.internal

V

valueOf(String) - Static method in enum org.davidmoten.rx2.io.internal.HttpMethod

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.davidmoten.rx2.io.internal.HttpMethod

Returns an array containing the constants of this enum type, in the order they are declared.

W

write(ByteBuffer) - Method in interface org.davidmoten.rx2.http.Writer

write(int) - Method in interface org.davidmoten.rx2.http.Writer

write(byte[], int, int) - Method in interface org.davidmoten.rx2.http.Writer

write(byte[]) - Method in interface org.davidmoten.rx2.http.Writer

Writer - Interface in org.davidmoten.rx2.http

writerFactory(WriterFactory) - Method in class org.davidmoten.rx2.http.Response.Builder

writerFactory() - Method in class org.davidmoten.rx2.http.Response

WriterFactory - Interface in org.davidmoten.rx2.http

A B C D F G H I J M N O P R S T U V W