| Package | Description | 
|---|---|
| au.gov.amsa.ais | |
| au.gov.amsa.ais.rx | |
| au.gov.amsa.util.nmea | 
| Modifier and Type | Method and Description | 
|---|---|
NmeaMessage | 
AisNmeaMessage.getNmea()  | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.base.Optional<List<NmeaMessage>> | 
AisNmeaBuffer.add(NmeaMessage nmea)
Returns the complete message only once the whole group of messages has
 arrived otherwise returns null. 
 | 
static com.google.common.base.Optional<NmeaMessage> | 
AisNmeaBuffer.concatenateMessages(List<NmeaMessage> list)
Returns the aggregated message or if an  
NmeaMessageParseException
 occurs returns null. | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.base.Optional<List<NmeaMessage>> | 
AisNmeaBuffer.add(NmeaMessage nmea)
Returns the complete message only once the whole group of messages has
 arrived otherwise returns null. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static com.google.common.base.Optional<NmeaMessage> | 
AisNmeaBuffer.concatenateMessages(List<NmeaMessage> list)
Returns the aggregated message or if an  
NmeaMessageParseException
 occurs returns null. | 
| Constructor and Description | 
|---|
AisNmeaMessage(NmeaMessage nmea)  | 
| Modifier and Type | Field and Description | 
|---|---|
static rx.functions.Func1<String,com.google.common.base.Optional<NmeaMessage>> | 
Streams.LINE_TO_NMEA_MESSAGE  | 
static rx.functions.Func1<NmeaMessage,com.google.common.base.Optional<Timestamped<AisMessage>>> | 
Streams.TO_AIS_MESSAGE  | 
static rx.functions.Func1<NmeaMessage,Streams.TimestampedAndLine<AisMessage>> | 
Streams.TO_AIS_MESSAGE_AND_LINE  | 
static rx.functions.Func1<com.google.common.base.Optional<List<NmeaMessage>>,Streams.TimestampedAndLines<AisMessage>> | 
Streams.TO_AIS_MESSAGE_AND_LINES  | 
| Modifier and Type | Method and Description | 
|---|---|
static rx.Observable.Transformer<NmeaMessage,com.google.common.base.Optional<List<NmeaMessage>>> | 
Streams.addToBuffer(int bufferSize)  | 
static rx.Observable.Transformer<NmeaMessage,com.google.common.base.Optional<List<NmeaMessage>>> | 
Streams.addToBuffer(int bufferSize)  | 
static rx.Observable.Transformer<NmeaMessage,NmeaMessage> | 
Streams.aggregateMultiLineNmea(int bufferSize)  | 
static rx.Observable.Transformer<NmeaMessage,NmeaMessage> | 
Streams.aggregateMultiLineNmea(int bufferSize)  | 
static rx.Observable.Transformer<NmeaMessage,NmeaMessage> | 
Streams.aggregateMultiLineNmeaWithLines(int bufferSize)  | 
static rx.Observable.Transformer<NmeaMessage,NmeaMessage> | 
Streams.aggregateMultiLineNmeaWithLines(int bufferSize)  | 
| Modifier and Type | Method and Description | 
|---|---|
NmeaMessage | 
NmeaMessageParser.parse(String line)
Return an  
NmeaMessage from the given NMEA line. | 
static NmeaMessage | 
NmeaUtil.parseNmea(String line)  | 
Copyright © 2020. All rights reserved.