1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
package kotlinx.serialization.json.internal
import kotlinx.serialization.*
import kotlinx.serialization.json.DecodeSequenceMode
import kotlinx.serialization.json.Json
@RequiresOptIn(level = RequiresOptIn.Level.ERROR)
internal annotation class JsonFriendModuleApi
@JsonFriendModuleApi
public interface InternalJsonWriter {
public fun writeLong(value: Long)
public fun writeChar(char: Char)
public fun write(text: String)
public fun writeQuoted(text: String)
public fun release()
}
@JsonFriendModuleApi
public interface InternalJsonReader {
public fun read(buffer: CharArray, bufferOffset: Int, count: Int): Int
}
@JsonFriendModuleApi
public fun <T> encodeByWriter(json: Json, writer: InternalJsonWriter, serializer: SerializationStrategy<T>, value: T) {
val encoder = StreamingJsonEncoder(
writer, json,
WriteMode.OBJ,
arrayOfNulls(WriteMode.entries.size)
)
encoder.encodeSerializableValue(serializer, value)
}
@JsonFriendModuleApi
public fun <T> decodeByReader(
json: Json,
deserializer: DeserializationStrategy<T>,
reader: InternalJsonReader
): T {
val lexer = ReaderJsonLexer(reader)
try {
val input = StreamingJsonDecoder(json, WriteMode.OBJ, lexer, deserializer.descriptor, null)
val result = input.decodeSerializableValue(deserializer)
lexer.expectEof()
return result
} finally {
lexer.release()
}
}
@JsonFriendModuleApi
@ExperimentalSerializationApi
public fun <T> decodeToSequenceByReader(
json: Json,
reader: InternalJsonReader,
deserializer: DeserializationStrategy<T>,
format: DecodeSequenceMode = DecodeSequenceMode.AUTO_DETECT
): Sequence<T> {
val lexer = ReaderJsonLexer(reader, CharArray(BATCH_SIZE)) // Unpooled buffer due to lazy nature of sequence
val iter = JsonIterator(format, json, lexer, deserializer)
return Sequence { iter }.constrainOnce()
}
@JsonFriendModuleApi
@ExperimentalSerializationApi
public inline fun <reified T> decodeToSequenceByReader(
json: Json,
reader: InternalJsonReader,
format: DecodeSequenceMode = DecodeSequenceMode.AUTO_DETECT
): Sequence<T> = decodeToSequenceByReader(json, reader, json.serializersModule.serializer(), format)
|
