@@ -0,0 +1,1049 @@
+package au.gov.amsa.geo.adhoc;%0A%0Aimport java.io.File;%0A%0Aimport au.gov.amsa.ais.message.AisAidToNavigation;%0Aimport au.gov.amsa.ais.rx.Streams;%0A%0Apublic class AdHocMain %7B%0A    public static void main(String%5B%5D args) %7B%0A        Streams.extract(Streams.nmeaFrom(new File(%22/media/an/temp/2015-11-12.txt%22)))%0A                //%0A                .filter(m -%3E m.getMessage().isPresent())%0A                //%0A                .filter(m -%3E m.getMessage().get().message().getMessageId() == 21)%0A                //%0A                // .map(m -%3E (AisShipStatic) m.getMessage().get().message())%0A%0A                //%0A                .map(m -%3E (AisAidToNavigation) m.getMessage().get().message())%0A                //%0A                .filter(m -%3E String.valueOf(m.getMmsi()).startsWith(%22999%22))%0A                // .distinct(m -%3E m.getMmsi())%0A                // .filter(m -%3E m.getMmsi() == 553111494)%0A                //%0A                .doOnNext(System.out::println).subscribe();%0A    %7D%0A%0A    private static boolean isAton(String mmsi) %7B%0A        return mmsi.startsWith(%2299%22);%0A    %7D%0A%7D%0A

add AdHocMain