| Package | Description |
|---|---|
| org.davidmoten.rx2.http | |
| org.davidmoten.rx2.io.internal |
| Modifier and Type | Method and Description |
|---|---|
AfterOnNextFactory |
Response.afterOnNextFactory() |
| Modifier and Type | Field and Description |
|---|---|
static AfterOnNextFactory |
AfterOnNextFactory.DEFAULT |
| Modifier and Type | Method and Description |
|---|---|
static AfterOnNextFactory |
AfterOnNextFactory.flushAfter(int numItems,
int numBytes) |
| Modifier and Type | Method and Description |
|---|---|
static void |
Server.handle(org.reactivestreams.Publisher<? extends ByteBuffer> flowable,
io.reactivex.SingleSource<OutputStream> out,
Runnable completion,
long id,
io.reactivex.Scheduler requestScheduler,
io.reactivex.functions.Consumer<org.reactivestreams.Subscription> subscription,
WriterFactory writerFactory,
AfterOnNextFactory afterOnNextFactory) |
Copyright © 2018–2019. All rights reserved.