val buffer = Buffer() // gets filled until a specific condition
val packetList = listOf(/*a list of bytearrays aka packets*)

packetList.forEach { packet ->
	fun parse(buffer, packet) {
		buffer.write(packet)
		while (size != 0L) {
		  // do some read and skip operations
		  // need to remove 4 bytes from end of buffer, then return from parse and write the next packet until specific condition occurs
		}
    }
}

while (size != 0L) {
    ...
	val tmpBuffer = Buffer()
	buffer.copyTo(tmpBuffer, consumableRestOfBytes)
	
	buffer.clear()
	buffer.write(tmpBuffer.readByteArray())
	
	return
...

deriveSchemaFromMigrations = true

idea.log

companyApiModule

[OkHttp]

callTimeout

Interceptor

CallAdapter.Factory

Interceptor

fun LocalDb.getCountriesList() : List<CountryData> {
    return countriesQueries.getCountriesList(
        mapper = { name, population, first_doses, fully_vaccinated ->
            CountryData(name = name, population = population, firstDoses = first_doses, fullyVaccinated = fully_vaccinated)
        }).executeAsList()
}

//Module A
sqldelight {
    MyDatabase {
        packageName = "com.package.name.A"
    }
}

//Module B
sqldelight {
    MyDatabase {
        packageName = "com.package.name.B"
        dependency project(':moduleA')
    }
}

MyDatabase

MyDatabase(AndroidSqliteDriver(MyDatabase.Schema), context)

by

class NewApi(realApi: Api) : Api by realApi

public static <T> Response<T> success(T body) {

public static <T> Response<T> success(T body, com.squareup.okhttp.Response rawResponse)

public static <T> Response<T> error(int code, ResponseBody body) {

return delegate.returning(Calls.response("Colton Idle"))

edit: freakin slack formatting

body()