OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
return topicAdmin.listTopicSubscriptions(topicPath.getPath()).iterateAll();return Streams.stream(topicAdmin.listTopicSubscriptions(topicPath.getPath()).iterateAll()).filter((path) -> !path.equals(subscriptionPath.getPath())).collect(Collectors.toList());topicAdmin.listTopicSubscriptions(topicPath.getPath()).iterateAll()Streams.stream(topicAdmin.listTopicSubscriptions(topicPath.getPath()).iterateAll()).filter((path) -> !path.equals(subscriptionPath.getPath())).collect(Collectors.toList())beamc56c33b2f5fc042c57776e9b07c7bce7650be8e4org.apache.beam.sdk.io.gcp.pubsub.TestPubsub
_1230
_2231
_1listSubscriptions
_2listSubscriptions
v0topicPath.getPath()
v1topicAdmin
  • java.util.stream.Collectors
  • org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Streams
v0topicPath.getPath()
v1topicAdmin
ReturnsFalse