| 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.