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