public class GPFDistServer
extends java.lang.Object
| Constructor and Description |
|---|
GPFDistServer(org.reactivestreams.Processor<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> processor,
int port,
int flushCount,
int flushTime,
int batchTimeout,
int batchCount) |
| Modifier and Type | Method and Description |
|---|---|
int |
getLocalPort() |
reactor.io.net.http.HttpServer<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> |
start() |
void |
stop() |