Package | Description |
---|---|
au.gov.amsa.ais | |
au.gov.amsa.ais.rx | |
au.gov.amsa.ais.rx.operators | |
au.gov.amsa.navigation |
Modifier and Type | Method and Description |
---|---|
static <T extends AisMessage> |
Timestamped.create(T message,
long time) |
Timestamped<AisMessage> |
AisNmeaMessage.getTimestampedMessage() |
Timestamped<AisMessage> |
AisNmeaMessage.getTimestampedMessage(long defaultTime) |
Modifier and Type | Field and Description |
---|---|
static rx.functions.Func1<NmeaMessage,com.google.common.base.Optional<Timestamped<AisMessage>>> |
Streams.TO_AIS_MESSAGE |
Modifier and Type | Method and Description |
---|---|
static rx.Observable<Timestamped<AisMessage>> |
Streams.extractMessages(rx.Observable<String> rawAisNmea) |
com.google.common.base.Optional<Timestamped<T>> |
Streams.TimestampedAndLines.getMessage() |
com.google.common.base.Optional<Timestamped<T>> |
Streams.TimestampedAndLine.getMessage() |
Constructor and Description |
---|
TimestampedAndLine(com.google.common.base.Optional<Timestamped<T>> message,
String line,
String error) |
TimestampedAndLines(com.google.common.base.Optional<Timestamped<T>> message,
List<String> lines,
String error) |
Modifier and Type | Method and Description |
---|---|
rx.Subscriber<? super Timestamped<? extends AisMessage>> |
OperatorCraftProperty.call(rx.Subscriber<? super CraftProperty> child) |
Modifier and Type | Method and Description |
---|---|
static rx.Observable<Timestamped<AisShipStatic>> |
ShipStaticDataCreator.writeStaticDataToFileWithTimestamps(List<File> files,
File outputFile,
rx.Scheduler scheduler) |
Copyright © 2020. All rights reserved.