This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 1fc810860 remove unused imports (#1524)
1fc810860 is described below
commit 1fc810860c1b7d4efeebb2819a018e2ff35edc6f
Author: PJ Fanning <[email protected]>
AuthorDate: Tue Mar 24 23:48:26 2026 +0100
remove unused imports (#1524)
---
.../connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala
index 4f8172945..edf0f0af8 100644
---
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala
+++
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala
@@ -15,6 +15,7 @@ package
org.apache.pekko.stream.connectors.googlecloud.pubsub.grpc.javadsl
import java.time.Duration
import java.util.concurrent.{ CompletableFuture, CompletionStage,
ConcurrentHashMap }
+
import org.apache.pekko
import pekko.actor.Cancellable
import pekko.annotation.ApiMayChange
@@ -29,9 +30,7 @@ import
pekko.stream.connectors.googlecloud.pubsub.grpc.impl.FlowControlGateStage
import pekko.{ Done, NotUsed }
import com.google.pubsub.v1._
-import scala.concurrent.{ ExecutionContext, Future }
import scala.jdk.CollectionConverters._
-import scala.jdk.DurationConverters._
/**
* Google Pub/Sub Pekko Stream operator factory.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
