### Question:
ReflectionHelper { @SuppressWarnings("unchecked") public static List<String> getInputStreamNames(Class<? extends Component> componentClazz) { List<String> streams = new ArrayList<>(); Set<Field> fields = getAllFields(componentClazz, withAnnotation(InputStream.class)); for (Field field : fields) { String streamName = field.getAnnotation(InputStream.class).name(); streams.add(streamName); } return streams; }  @SuppressWarnings("unchecked") static Map<String, Stream> getOutputStreams(Component component); @SuppressWarnings("unchecked") static Stream getOutputStream(Object obj, String name); @SuppressWarnings("unchecked") static List<String> getInputStreamNames(Class<? extends Component> componentClazz); static void setProperties(Object obj, List<PropertyConfiguration> properties); static void setInputStreams(Component component, Map<String, Stream> inputStreams); @SuppressWarnings("unchecked") static void setTopology(Component component, TridentTopology topology); @SuppressWarnings("unchecked") static void setConfiguration(Component component, Config config); @SuppressWarnings("unchecked") static void setFeaturesMapper(Component component, String streamName, NamedFeaturesMapper mapper); @SuppressWarnings("unchecked") static void setFeaturesMapper(Component component, String streamName, ListedFeaturesMapper mapper); @SuppressWarnings("unchecked") static void setStateFactory(Component component, String stateName, StateFactory stateFactory); @SuppressWarnings("unchecked") static void setInputStream(Component component, String name, Stream stream); @SuppressWarnings("unchecked") static NameMapper getNameMapper(Class<?> clazz, String stream); @SuppressWarnings("unchecked") static ListMapper getListMapper(Class<?> clazz, String stream); @SuppressWarnings({ "unchecked", "rawtypes" }) static Object getEnumValue(Class<?> clazz, String name);  }### Answer:
@Test public void should_find_input_streams() { class TestComponent implements Component { @InputStream(name = "in1") public Stream clock; @InputStream(name = "in2") public Stream words; @Override public void init() { } } List<String> actualInputStreams = ReflectionHelper.getInputStreamNames(TestComponent.class); assertThat(actualInputStreams).containsOnly("in1", "in2"); }