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()) | beam | c56c33b2f5fc042c57776e9b07c7bce7650be8e4 | org.apache.beam.sdk.io.gcp.pubsub.TestPubsub | | _1 | listSubscriptions |
---|
_2 | listSubscriptions |
---|
| v0 | topicPath.getPath() |
---|
v1 | topicAdmin |
---|
| - java.util.stream.Collectors
- org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Streams
| v0 | topicPath.getPath() |
---|
v1 | topicAdmin |
---|
| Returns | False |