Constructor and Description |
---|
ServerSocketBuilder(Callable<? extends ServerSocket> serverSocketFactory) |
Modifier and Type | Method and Description |
---|---|
IO.ServerSocketBuilder |
acceptSocketIf(io.reactivex.functions.Predicate<? super Socket> acceptSocket) |
IO.ServerSocketBuilder |
acceptTimeoutMs(int acceptTimeoutMs) |
IO.ServerSocketBuilder |
bufferSize(int bufferSize) |
io.reactivex.Flowable<io.reactivex.Flowable<byte[]>> |
create() |
IO.ServerSocketBuilder |
preAcceptAction(io.reactivex.functions.Action action) |
IO.ServerSocketBuilder |
readTimeoutMs(int readTimeoutMs) |
public ServerSocketBuilder(Callable<? extends ServerSocket> serverSocketFactory)
public IO.ServerSocketBuilder readTimeoutMs(int readTimeoutMs)
public IO.ServerSocketBuilder bufferSize(int bufferSize)
public IO.ServerSocketBuilder preAcceptAction(io.reactivex.functions.Action action)
public IO.ServerSocketBuilder acceptTimeoutMs(int acceptTimeoutMs)
public IO.ServerSocketBuilder acceptSocketIf(io.reactivex.functions.Predicate<? super Socket> acceptSocket)
public io.reactivex.Flowable<io.reactivex.Flowable<byte[]>> create()
Copyright © 2013–2020. All rights reserved.