org.davidmoten.rx2.io.internal

Class Server

java.lang.Object

org.davidmoten.rx2.io.internal.Server

public final class Server
extends Object

Method Summary

Modifier and Type	Method and Description
static void	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

handle

public static void 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)