Skip to content

Update scalafmt-core to 3.9.8 #652

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 3 commits into from
+28 −26
Closed

Update scalafmt-core to 3.9.8 #652

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
359f474
Update scalafmt-core to 3.9.8
scala-steward Jun 29, 2025
c89b767
Reformat with scalafmt 3.9.8
scala-steward Jun 29, 2025
cf2d1a3
Add 'Reformat with scalafmt 3.9.8' to .git-blame-ignore-revs
scala-steward Jun 29, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions .git-blame-ignore-revs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
# Scala Steward: Reformat with scalafmt 3.9.8
c89b7675fa21be644e7f7a22e5f2cfbbab74e1e5
2 changes: 1 addition & 1 deletion .scalafmt.conf
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
version=3.8.6
version=3.9.8
runner.dialect = scala213
align.openParenCallSite = true
align.openParenDefnSite = true
Expand Down
2 changes: 1 addition & 1 deletion build.sbt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ inThisBuild(
organizationHomepage := Some(url("https://github.com/azhur")),
homepage := Some(url("https://github.com/azhur/kafka-serde-scala")),
licenses := List("Apache-2.0" -> url("http://www.apache.org/licenses/LICENSE-2.0")),
scmInfo := Some(
scmInfo := Some(
ScmInfo(
url("https://github.com/azhur/kafka-serde-scala"),
"git@github.com:azhur/kafka-serde-scala.git"
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sBinarySupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ trait Avro4sBinarySupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else {
val baos = new ByteArrayOutputStream()
Expand All @@ -54,7 +54,7 @@ trait Avro4sBinarySupport {
private val schema = AvroSchema[T]
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else {
val it = AvroInputStream.binary[T].from(data).build(schema).tryIterator
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sDataSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ trait Avro4sDataSupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else {
val baos = new ByteArrayOutputStream()
Expand All @@ -58,7 +58,7 @@ trait Avro4sDataSupport {
private val schema = AvroSchema[T]
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else {
val it = AvroInputStream.data[T].from(data).build(schema).tryIterator
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sJsonSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ trait Avro4sJsonSupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else {
val baos = new ByteArrayOutputStream()
Expand All @@ -54,7 +54,7 @@ trait Avro4sJsonSupport {
private val schema = AvroSchema[T]
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else {
val it = AvroInputStream.json[T].from(data).build(schema).tryIterator
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-circe/src/main/scala/io/github/azhur/kafka/serde/CirceSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ trait CirceSupport {
import io.circe.syntax._
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else
try printer.print(data.asJson).getBytes(UTF_8)
Expand All @@ -50,7 +50,7 @@ trait CirceSupport {

override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else
parser
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/Jackson.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@ import java.lang.reflect.{ ParameterizedType, Type => JType }

object Jackson {
def typeReference[T: TypeTag]: TypeReference[T] = {
val t = typeTag[T]
val mirror = t.mirror
val t = typeTag[T]
val mirror = t.mirror
def mapType(t: Type): JType =
if (t.typeArgs.isEmpty) {
mirror.runtimeClass(t)
Expand Down
4 changes: 2 additions & 2 deletions ...serde-jackson/src/main/scala/io/github/azhur/kafka/serde/JacksonFormatSchemaSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ trait JacksonFormatSchemaSupport {
private val writer = mapper.writer(schema)
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else
try writer.writeValueAsBytes(data)
Expand All @@ -55,7 +55,7 @@ trait JacksonFormatSchemaSupport {
private val reader = mapper.readerFor(typeReference[T]).`with`(schema)
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else
try reader.readValue[T](data)
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/JacksonJsonSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ trait JacksonJsonSupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else
try mapper.writeValueAsBytes(data)
Expand All @@ -48,7 +48,7 @@ trait JacksonJsonSupport {
private val tr = typeReference[T]
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else
try mapper.readValue[T](data, tr)
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-json4s/src/main/scala/io/github/azhur/kafka/serde/Json4sSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ trait Json4sSupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else
try serialization.write[T](data).getBytes(UTF_8)
Expand All @@ -50,7 +50,7 @@ trait Json4sSupport {
new Deserializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else
try serialization.read[T](new String(data, UTF_8))
Expand Down
4 changes: 2 additions & 2 deletions ...erde-jsoniter-scala/src/main/scala/io/github/azhur/kafka/serde/JsoniterScalaSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ trait JsoniterScalaSupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else
try writeToArray(data, writerConfig)
Expand All @@ -48,7 +48,7 @@ trait JsoniterScalaSupport {
new Deserializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else
try readFromArray(data, readerConfig)
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-play-json/src/main/scala/io/github/azhur/kafka/serde/PlayJsonSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ trait PlayJsonSupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else
try printer(writes.writes(data)).getBytes(UTF_8)
Expand All @@ -49,7 +49,7 @@ trait PlayJsonSupport {
new Deserializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else
reads
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-upickle/src/main/scala/io/github/azhur/kafka/serde/UpickleSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ trait UpickleSupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else
try write(data).getBytes(UTF_8)
Expand All @@ -43,7 +43,7 @@ trait UpickleSupport {
new Deserializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else
try read(new String(data, UTF_8))
Expand Down
4 changes: 2 additions & 2 deletions kafka-serde-zio-json/src/main/scala/io/github/azhur/kafka/serde/ZioJsonSupport.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ trait ZioJsonSupport {
new Serializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def serialize(topic: String, data: T): Array[Byte] =
override def serialize(topic: String, data: T): Array[Byte] =
if (data == null) null
else
try data.toJson.getBytes(UTF_8)
Expand All @@ -43,7 +43,7 @@ trait ZioJsonSupport {
new Deserializer[T] {
override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
override def close(): Unit = {}
override def deserialize(topic: String, data: Array[Byte]): T =
override def deserialize(topic: String, data: Array[Byte]): T =
if (data == null) null
else
decoder.decodeJson(new String(data, UTF_8)) match {
Expand Down
Loading