Uses of Class
au.gov.amsa.ais.rx.Streams.TimestampedAndLine

Packages that use Streams.TimestampedAndLine

Package	Description
au.gov.amsa.ais.rx
au.gov.amsa.navigation.ais

Uses of Streams.TimestampedAndLine in au.gov.amsa.ais.rx

Fields in au.gov.amsa.ais.rx with type parameters of type Streams.TimestampedAndLine

Modifier and Type	Field and Description
static rx.functions.Func1<NmeaMessage,Streams.TimestampedAndLine<AisMessage>>	Streams.TO_AIS_MESSAGE_AND_LINE

Methods in au.gov.amsa.ais.rx that return types with arguments of type Streams.TimestampedAndLine

Modifier and Type	Method and Description
static rx.Observable<Streams.TimestampedAndLine<AisMessage>>	Streams.connectAndExtract(String host, int port)
static rx.Observable<Streams.TimestampedAndLine<AisMessage>>	Streams.extract(rx.Observable<String> rawAisNmea)

Uses of Streams.TimestampedAndLine in au.gov.amsa.navigation.ais

Fields in au.gov.amsa.navigation.ais with type parameters of type Streams.TimestampedAndLine

Modifier and Type	Field and Description
static rx.functions.Func2<AisMessageAndVesselData,Streams.TimestampedAndLine<AisMessage>,AisMessageAndVesselData>	AisMessageAndVesselData.aggregate

Methods in au.gov.amsa.navigation.ais that return types with arguments of type Streams.TimestampedAndLine

Modifier and Type	Method and Description
com.google.common.base.Optional<Streams.TimestampedAndLine<AisMessage>>	AisMessageAndVesselData.message()
static rx.Observable<Streams.TimestampedAndLine<AisMessage>>	AisVesselPositions.sortByTime(rx.Observable<Streams.TimestampedAndLine<AisMessage>> source)

Method parameters in au.gov.amsa.navigation.ais with type arguments of type Streams.TimestampedAndLine

Modifier and Type	Method and Description
static rx.Observable<Streams.TimestampedAndLine<AisMessage>>	AisVesselPositions.sortByTime(rx.Observable<Streams.TimestampedAndLine<AisMessage>> source)

Constructor parameters in au.gov.amsa.navigation.ais with type arguments of type Streams.TimestampedAndLine

Constructor and Description
AisMessageAndVesselData(com.google.common.base.Optional<Streams.TimestampedAndLine<AisMessage>> message, VesselData data)