tauri-plugin-serialplugin 2.22.0

Access the current process of your Tauri application.
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

package app.tauri.serialplugin.manager

import java.io.ByteArrayOutputStream

/**
 * Thread-safe byte buffer for coalescing serial chunks before emitting to JS.
 * Pure JVM logic — unit-testable without Robolectric.
 */
internal class SerialByteAccumulator {
    private val lock = Any()
    private val stream = ByteArrayOutputStream()

    fun append(data: ByteArray) {
        if (data.isEmpty()) return
        synchronized(lock) {
            stream.write(data)
        }
    }

    /**
     * Returns all accumulated bytes and clears the buffer.
     * Returns an empty array if nothing was pending.
     */
    fun drain(): ByteArray {
        synchronized(lock) {
            if (stream.size() == 0) return ByteArray(0)
            val b = stream.toByteArray()
            stream.reset()
            return b
        }
    }

    fun pendingByteCount(): Int = synchronized(lock) { stream.size() }
}