Constructor and Description |
---|
ServerSocketBuilder(rx.functions.Func0<? extends ServerSocket> serverSocketFactory) |
Modifier and Type | Method and Description |
---|---|
IO.ServerSocketBuilder |
acceptSocketIf(rx.functions.Func1<? super Socket,Boolean> acceptSocket) |
IO.ServerSocketBuilder |
acceptTimeoutMs(int acceptTimeoutMs) |
IO.ServerSocketBuilder |
bufferSize(int bufferSize) |
rx.Observable<rx.Observable<byte[]>> |
create() |
IO.ServerSocketBuilder |
preAcceptAction(rx.functions.Action0 action) |
IO.ServerSocketBuilder |
readTimeoutMs(int readTimeoutMs) |
public ServerSocketBuilder(rx.functions.Func0<? extends ServerSocket> serverSocketFactory)
public IO.ServerSocketBuilder readTimeoutMs(int readTimeoutMs)
public IO.ServerSocketBuilder bufferSize(int bufferSize)
public IO.ServerSocketBuilder preAcceptAction(rx.functions.Action0 action)
public IO.ServerSocketBuilder acceptTimeoutMs(int acceptTimeoutMs)
public IO.ServerSocketBuilder acceptSocketIf(rx.functions.Func1<? super Socket,Boolean> acceptSocket)
public rx.Observable<rx.Observable<byte[]>> create()
Copyright © 2013–2016. All rights reserved.