@Test void getTokenForStream() { assertEquals(new GlobalSequenceTrackingToken(0), testSubject.getTokenForStream("token1")); }
public TrackingToken getTokenForStream(String streamName) { return trackingTokens.get(streamName); }
MultiSourceTrackingToken implements TrackingToken, Serializable { public TrackingToken getTokenForStream(String streamName) { return trackingTokens.get(streamName); } }
MultiSourceTrackingToken implements TrackingToken, Serializable { public TrackingToken getTokenForStream(String streamName) { return trackingTokens.get(streamName); } @JsonCreator @ConstructorProperties({"trackingTokens"})  MultiSourceTrackingToken(@JsonProperty("trackingTokens") Map<String, TrackingToken> trackingTokens); }
MultiSourceTrackingToken implements TrackingToken, Serializable { public TrackingToken getTokenForStream(String streamName) { return trackingTokens.get(streamName); } @JsonCreator @ConstructorProperties({"trackingTokens"})  MultiSourceTrackingToken(@JsonProperty("trackingTokens") Map<String, TrackingToken> trackingTokens); @Override TrackingToken lowerBound(TrackingToken other); @Override TrackingToken upperBound(TrackingToken other); @Override boolean covers(TrackingToken other); MultiSourceTrackingToken advancedTo(String streamName, TrackingToken newTokenForStream); TrackingToken getTokenForStream(String streamName); Map<String, TrackingToken> getTrackingTokens(); @Override OptionalLong position(); @Override boolean equals(Object o); @Override int hashCode(); @Override String toString(); }
MultiSourceTrackingToken implements TrackingToken, Serializable { public TrackingToken getTokenForStream(String streamName) { return trackingTokens.get(streamName); } @JsonCreator @ConstructorProperties({"trackingTokens"})  MultiSourceTrackingToken(@JsonProperty("trackingTokens") Map<String, TrackingToken> trackingTokens); @Override TrackingToken lowerBound(TrackingToken other); @Override TrackingToken upperBound(TrackingToken other); @Override boolean covers(TrackingToken other); MultiSourceTrackingToken advancedTo(String streamName, TrackingToken newTokenForStream); TrackingToken getTokenForStream(String streamName); Map<String, TrackingToken> getTrackingTokens(); @Override OptionalLong position(); @Override boolean equals(Object o); @Override int hashCode(); @Override String toString();  }