public List process()

in local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/example/TwitterUserstreamElasticsearch.java [123:133]

• 7 lines of code
• 1 McCabe index (conditional complexity)

    public List<StreamsDatum> process(StreamsDatum entry) {

      MatcherAssert.assertThat(entry.getDocument(), IsInstanceOf.instanceOf(Activity.class));
      String id = entry.getId();
      // replace delete with post in id
      // ensure ElasticsearchPersistDeleter will remove original post if present
      id = StringUtils.replace(id, "delete", "post");
      entry.setId(id);

      return Stream.of(entry).collect(Collectors.toList());
    }