Method provide

src/audio_pdm/BLEStream.cpp:57–100

}

int BLEStream::provide(int max_cont) {
    if (!_stream) return 0;

    int cont = min((*stream)->get_contiguous_blocks(), max_cont);

    if (!cont) return 0;

    if (initial_drop > 0) {
        const int n = min(initial_drop, cont);
        (*stream)->provide(n);
        initial_drop -= n;
        cont -= n;

        if (!cont) return n;
    }

    uint8_t *read_pointer = (*stream)->buffer.getReadPointer();
    const int block_size = (*stream)->buffer.getBlockSize();

    for (int i = 0; i<cont; i++) {
        for (int k = 0; k < block_size; k+=down_sample * sizeof(int16_t)) {
            memcpy(sos_buffer, read_pointer + i * block_size + k, down_sample * sizeof(int16_t));
            filter->update((int16_t *) sos_buffer, down_sample);
            ble_buffer[index_ble++] = sos_buffer[0];
            if (index_ble == AUDIO_STREAM_PACKAGE_SIZE) {
                index_ble = 0;

                sensorProvider.update_manager();
                pdm_sensor.setBuffer((uint8_t*) ble_buffer);
                sensorProvider.update_sensor(PDM_MIC, true);
                bleHandler_G.update();

                delay(8);
            }
        }
    }

    // Serial.print("PDM: ");
    // Serial.println(recorder.available() ? (*recorder.target->stream)->remaining() : -1);

    (*stream)->provide(cont);

    return cont;
}

void BLEStream::start() {
    if (_stream) return;