@@ -0,0 +1,602 @@
+package au.gov.amsa.geo.adhoc;%0A%0Aimport java.io.File;%0A%0Aimport com.github.davidmoten.rx.Actions;%0A%0Aimport au.gov.amsa.ais.rx.Streams;%0A%0Apublic class CountPositions %7B%0A%0A    public static void main(String%5B%5D args) %7B%0A        Streams.extract(Streams.nmeaFrom(new File(%22/media/an/temp/2018-01-29.txt%22)))// //%0A                .filter(m -%3E m.getMessage().isPresent()) //%0A                .map(m -%3E m.getMessage().get().message().getMessageId()) //%0A                .filter(id -%3E id %3E= 1 && id %3C= 3) //%0A                .count() //%0A                .doOnNext(Actions.println()) //%0A                .subscribe();%0A    %7D%0A%0A%7D%0A

add CountPositions adhoc class