<BUG>targetTracker.readFromStream(aisPacketStream);</BUG><CONTEXT>import static java.util.Objects.requireNonNull;public class AisPacketFiltersStateful extends AisPacketFiltersBase {private AisPacketStream aisPacketStream = new AisPacketStreamImpl();private TargetTracker targetTracker = new TargetTracker();public AisPacketFiltersStateful() {<extra_id_0>}public Predicate<AisPacket> filterOnTargetImo(final CompareToOperator operator, Integer rhsImo) {final int imo = rhsImo;</CONTEXT>
targetTracker.subscribeToStream(aisPacketStream);