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-grpc.git
commit 11d72d769578cfde0242ecb63b48852702905e8a
Author: scala-steward-asf[bot]
<147768647+scala-steward-asf[bot]@users.noreply.github.com>
AuthorDate: Mon Oct 27 10:27:01 2025 +0000
Reformat with scalafmt 3.9.10
Executed command: scalafmt --non-interactive
---
.../src/main/scala/io/grpc/testing/integration2/Settings.scala | 2 +-
.../main/scala/org/apache/pekko/grpc/interop/GrpcInteropTests.scala | 2 +-
.../org/apache/pekko/grpc/interop/PekkoHttpServerProviderScala.scala | 2 +-
.../apache/pekko/grpc/scaladsl/GrpcExceptionDefaultHandleSpec.scala | 3 ++-
.../src/main/scala/example/myapp/statefulhelloworld/GreeterActor.scala | 2 +-
runtime/src/main/scala/org/apache/pekko/grpc/GrpcClientSettings.scala | 2 +-
.../scala/org/apache/pekko/grpc/internal/PekkoHttpClientUtils.scala | 2 +-
.../scala/org/apache/pekko/grpc/javadsl/GrpcExceptionHandler.scala | 2 +-
.../scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionHandler.scala | 2 +-
.../src/test/scala/org/apache/pekko/grpc/GrpcInteropSpec.scala | 2 +-
sbt-plugin/src/sbt-test/gen-scala-server/01-gen-basic-server/build.sbt | 2 +-
.../sbt-test/gen-scala-server/07-gen-basic-server-with-pekko/build.sbt | 2 +-
12 files changed, 13 insertions(+), 12 deletions(-)
diff --git
a/interop-tests/src/main/scala/io/grpc/testing/integration2/Settings.scala
b/interop-tests/src/main/scala/io/grpc/testing/integration2/Settings.scala
index 300e18da..26bac3da 100644
--- a/interop-tests/src/main/scala/io/grpc/testing/integration2/Settings.scala
+++ b/interop-tests/src/main/scala/io/grpc/testing/integration2/Settings.scala
@@ -113,7 +113,7 @@ object Settings {
case "default_service_account" => settings.copy(defaultServiceAccount
= value)
case "service_account_key_file" => settings.copy(serviceAccountKeyFile
= value)
case "oauth_scope" => settings.copy(oauthScope = value)
- case _ =>
+ case _ =>
System.err.println("Unknown argument: " + key)
showUsageAndExit()
settings // not really returning it because exiting, we need it for
compile check
diff --git
a/interop-tests/src/main/scala/org/apache/pekko/grpc/interop/GrpcInteropTests.scala
b/interop-tests/src/main/scala/org/apache/pekko/grpc/interop/GrpcInteropTests.scala
index b1e4dd62..db9e9406 100644
---
a/interop-tests/src/main/scala/org/apache/pekko/grpc/interop/GrpcInteropTests.scala
+++
b/interop-tests/src/main/scala/org/apache/pekko/grpc/interop/GrpcInteropTests.scala
@@ -107,7 +107,7 @@ class GrpcInteropTests(serverProvider: GrpcServerProvider,
clientProvider: GrpcC
Succeeded
} catch {
case NonFatal(_) if expectedToFail => pending
- case NonFatal(e) =>
+ case NonFatal(e) =>
e.printStackTrace()
throw e
}
diff --git
a/interop-tests/src/test/scala/org/apache/pekko/grpc/interop/PekkoHttpServerProviderScala.scala
b/interop-tests/src/test/scala/org/apache/pekko/grpc/interop/PekkoHttpServerProviderScala.scala
index 367bb43d..6a02f971 100644
---
a/interop-tests/src/test/scala/org/apache/pekko/grpc/interop/PekkoHttpServerProviderScala.scala
+++
b/interop-tests/src/test/scala/org/apache/pekko/grpc/interop/PekkoHttpServerProviderScala.scala
@@ -113,7 +113,7 @@ object PekkoHttpServerProviderScala extends
PekkoHttpServerProvider with Directi
HttpEntity.Chunked(
contentType,
data.map {
- case chunk: HttpEntity.Chunk => chunk
+ case chunk: HttpEntity.Chunk => chunk
case last: HttpEntity.LastChunk =>
HttpEntity.LastChunk(last.extension, f(last.trailer))
}))
diff --git
a/interop-tests/src/test/scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionDefaultHandleSpec.scala
b/interop-tests/src/test/scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionDefaultHandleSpec.scala
index 26ceff02..c79aeace 100644
---
a/interop-tests/src/test/scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionDefaultHandleSpec.scala
+++
b/interop-tests/src/test/scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionDefaultHandleSpec.scala
@@ -55,7 +55,8 @@ class GrpcExceptionDefaultHandleSpec
response.entity match {
case Chunked(_, chunks) =>
chunks.runWith(Sink.seq).futureValue match {
- case Seq(LastChunk("", List(`Status`("3")))) => // ok
+ case Seq(LastChunk("",
+ List(`Status`("3")))) => // ok
}
case _: Strict =>
response.headers.find(_.is("grpc-status")).map(_.value()) shouldBe
Some("3")
diff --git
a/plugin-tester-scala/src/main/scala/example/myapp/statefulhelloworld/GreeterActor.scala
b/plugin-tester-scala/src/main/scala/example/myapp/statefulhelloworld/GreeterActor.scala
index 5ce53fed..7f55bb5e 100644
---
a/plugin-tester-scala/src/main/scala/example/myapp/statefulhelloworld/GreeterActor.scala
+++
b/plugin-tester-scala/src/main/scala/example/myapp/statefulhelloworld/GreeterActor.scala
@@ -33,7 +33,7 @@ class GreeterActor(initialGreeting: String) extends Actor {
var greeting = Greeting(initialGreeting)
def receive = {
- case GetGreeting => sender() ! greeting
+ case GetGreeting => sender() ! greeting
case ChangeGreeting(newGreeting) =>
greeting = Greeting(newGreeting)
}
diff --git
a/runtime/src/main/scala/org/apache/pekko/grpc/GrpcClientSettings.scala
b/runtime/src/main/scala/org/apache/pekko/grpc/GrpcClientSettings.scala
index eba07229..8b933314 100644
--- a/runtime/src/main/scala/org/apache/pekko/grpc/GrpcClientSettings.scala
+++ b/runtime/src/main/scala/org/apache/pekko/grpc/GrpcClientSettings.scala
@@ -148,7 +148,7 @@ object GrpcClientSettings {
case "jdk" => SslProvider.JDK
case "openssl" => SslProvider.OPENSSL
case "openssl_refcnt" => SslProvider.OPENSSL_REFCNT
- case other =>
+ case other =>
throw new IllegalArgumentException(
s"ssl-provider: expected empty, 'jdk', 'openssl' or
'openssl_refcnt', but got [$other]")
},
diff --git
a/runtime/src/main/scala/org/apache/pekko/grpc/internal/PekkoHttpClientUtils.scala
b/runtime/src/main/scala/org/apache/pekko/grpc/internal/PekkoHttpClientUtils.scala
index 1723c1ec..bbf21236 100644
---
a/runtime/src/main/scala/org/apache/pekko/grpc/internal/PekkoHttpClientUtils.scala
+++
b/runtime/src/main/scala/org/apache/pekko/grpc/internal/PekkoHttpClientUtils.scala
@@ -98,7 +98,7 @@ object PekkoHttpClientUtils {
ConnectionContext.httpsClient {
settings.sslContext.getOrElse {
settings.trustManager match {
- case None => SSLContext.getDefault
+ case None => SSLContext.getDefault
case Some(trustManager) =>
val sslContext: SSLContext = SSLContext.getInstance("TLS")
sslContext.init(Array[KeyManager](),
Array[TrustManager](trustManager), new SecureRandom)
diff --git
a/runtime/src/main/scala/org/apache/pekko/grpc/javadsl/GrpcExceptionHandler.scala
b/runtime/src/main/scala/org/apache/pekko/grpc/javadsl/GrpcExceptionHandler.scala
index b3a69968..e3287087 100644
---
a/runtime/src/main/scala/org/apache/pekko/grpc/javadsl/GrpcExceptionHandler.scala
+++
b/runtime/src/main/scala/org/apache/pekko/grpc/javadsl/GrpcExceptionHandler.scala
@@ -61,7 +61,7 @@ object GrpcExceptionHandler {
case e: NotImplementedError =>
Trailers(Status.UNIMPLEMENTED.withDescription(e.getMessage))
case e: UnsupportedOperationException =>
Trailers(Status.UNIMPLEMENTED.withDescription(e.getMessage))
case e: StatusRuntimeException => Trailers(e.getStatus,
new GrpcMetadataImpl(e.getTrailers))
- case e: PeerClosedStreamException =>
+ case e: PeerClosedStreamException =>
log(system).warning(e, "Peer closed the stream: [{}]",
e.getMessage)
INTERNAL
case other =>
diff --git
a/runtime/src/main/scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionHandler.scala
b/runtime/src/main/scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionHandler.scala
index 232404a6..bf84958f 100644
---
a/runtime/src/main/scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionHandler.scala
+++
b/runtime/src/main/scala/org/apache/pekko/grpc/scaladsl/GrpcExceptionHandler.scala
@@ -42,7 +42,7 @@ object GrpcExceptionHandler {
case e: NotImplementedError =>
Trailers(Status.UNIMPLEMENTED.withDescription(e.getMessage))
case e: UnsupportedOperationException =>
Trailers(Status.UNIMPLEMENTED.withDescription(e.getMessage))
case _: MissingParameterException => INVALID_ARGUMENT
- case e: StatusRuntimeException =>
+ case e: StatusRuntimeException =>
val meta = Option(e.getTrailers).getOrElse(new io.grpc.Metadata())
Trailers(e.getStatus, new GrpcMetadataImpl(meta))
case e: PeerClosedStreamException =>
diff --git
a/sbt-plugin/src/sbt-test/gen-scala-server/00-interop/src/test/scala/org/apache/pekko/grpc/GrpcInteropSpec.scala
b/sbt-plugin/src/sbt-test/gen-scala-server/00-interop/src/test/scala/org/apache/pekko/grpc/GrpcInteropSpec.scala
index d7686830..408f2da9 100644
---
a/sbt-plugin/src/sbt-test/gen-scala-server/00-interop/src/test/scala/org/apache/pekko/grpc/GrpcInteropSpec.scala
+++
b/sbt-plugin/src/sbt-test/gen-scala-server/00-interop/src/test/scala/org/apache/pekko/grpc/GrpcInteropSpec.scala
@@ -69,7 +69,7 @@ object PekkoHttpServerProviderScala extends
PekkoHttpServerProvider {
HttpEntity.Chunked(
contentType,
data.map {
- case chunk: HttpEntity.Chunk => chunk
+ case chunk: HttpEntity.Chunk => chunk
case last: HttpEntity.LastChunk =>
HttpEntity.LastChunk(last.extension, f(last.trailer))
}))
diff --git
a/sbt-plugin/src/sbt-test/gen-scala-server/01-gen-basic-server/build.sbt
b/sbt-plugin/src/sbt-test/gen-scala-server/01-gen-basic-server/build.sbt
index 75d0ae27..6283db84 100644
--- a/sbt-plugin/src/sbt-test/gen-scala-server/01-gen-basic-server/build.sbt
+++ b/sbt-plugin/src/sbt-test/gen-scala-server/01-gen-basic-server/build.sbt
@@ -17,7 +17,7 @@ assembly / assemblyMergeStrategy := {
// https://github.com/akka/akka/issues/29456
case PathList("google", "protobuf", _*) => MergeStrategy.discard
case PathList("META-INF", _*) => MergeStrategy.discard
- case x =>
+ case x =>
val oldStrategy = (assembly / assemblyMergeStrategy).value
oldStrategy(x)
}
diff --git
a/sbt-plugin/src/sbt-test/gen-scala-server/07-gen-basic-server-with-pekko/build.sbt
b/sbt-plugin/src/sbt-test/gen-scala-server/07-gen-basic-server-with-pekko/build.sbt
index 7e2b6ca3..87db8c9a 100644
---
a/sbt-plugin/src/sbt-test/gen-scala-server/07-gen-basic-server-with-pekko/build.sbt
+++
b/sbt-plugin/src/sbt-test/gen-scala-server/07-gen-basic-server-with-pekko/build.sbt
@@ -15,7 +15,7 @@ assembly / assemblyMergeStrategy := {
// https://github.com/akka/akka/issues/29456
case PathList("google", "protobuf", _*) => MergeStrategy.discard
case PathList("META-INF", _*) => MergeStrategy.discard
- case x =>
+ case x =>
val oldStrategy = (assembly / assemblyMergeStrategy).value
oldStrategy(x)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]