Package | Description |
---|---|
au.gov.amsa.streams |
Modifier and Type | Method and Description |
---|---|
static HostPort |
HostPort.create(String host,
int port,
long quietTimeoutMs,
long reconnectDelayMs) |
Modifier and Type | Method and Description |
---|---|
static rx.Observable<String> |
StringSockets.mergeLinesFrom(rx.Observable<HostPort> hostPorts) |
static rx.Observable<String> |
StringSockets.mergeLinesFrom(rx.Observable<HostPort> hostPorts,
int maxLineLength) |
static rx.Observable<String> |
StringSockets.mergeLinesFrom(rx.Observable<HostPort> hostPorts,
rx.Scheduler scheduler) |
static rx.Observable<String> |
StringSockets.mergeLinesFrom(rx.Observable<HostPort> hostPorts,
rx.Scheduler scheduler,
int maxLineLength) |
Copyright © 2020. All rights reserved.