Added reader method that accepts ByteArray

sksamuel · Apr 15, 2024 · cce1d25 · cce1d25
1 parent 680a01b
commit cce1d25
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 64 deletions.
diff --git a/centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/Encoders.kt b/centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/Encoders.kt
diff --git a/centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/Records.kt b/centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/Records.kt
diff --git a/centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/io/AvroBinaryReader.kt b/centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/io/AvroBinaryReader.kt
@@ -23,9 +23,16 @@ class AvroBinaryReaderFactory(schema: Schema, private val factory: DecoderFactor
     * This variant is much slower than using a byte array. If you already have
     * the bytes available, that should be preferred.
     */
-   fun writer(input: InputStream): AvroBinaryReader {
+   fun reader(input: InputStream): AvroBinaryReader {
       return AvroBinaryReader(datumReader, input, null, factory)
    }
+
+   /**
+    * Creates an [AvroBinaryReader] that reads from the given [ByteArray].
+    */
+   fun reader(bytes: ByteArray): AvroBinaryReader {
+      return AvroBinaryReader(datumReader, null, bytes, factory)
+   }
 }
 
 /**