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.