@Test public void hasNext() { assertThat(reader.hasNext()).isTrue(); }
@Override public boolean hasNext() { return true; }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public boolean hasNext() { return true; } }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public boolean hasNext() { return true; } private  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, Properties consumerProperties); @VisibleForTesting  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, KafkaConsumer<Long, byte[]> consumer); }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public boolean hasNext() { return true; } private  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, Properties consumerProperties); @VisibleForTesting  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, KafkaConsumer<Long, byte[]> consumer); @Override ApiaryListenerEvent next(); @Override boolean hasNext(); @Override void remove(); @Override void close(); }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public boolean hasNext() { return true; } private  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, Properties consumerProperties); @VisibleForTesting  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, KafkaConsumer<Long, byte[]> consumer); @Override ApiaryListenerEvent next(); @Override boolean hasNext(); @Override void remove(); @Override void close();  }