| 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 |