* garrow_stream_decoder_consume_bytes: * @decoder: A #GArrowStreamDecoder. * @bytes: A #GBytes to be decoded. * @error: (nullable): Return location for a #GError or %NULL. * * Feed data to the decoder as a raw data. * * If the decoder can read one or more record batches by the data, the * decoder calls [vfunc@GArrowStreamListener.on_record_batch_decoded] * with a decoded record batch mult
| 425 | * Since: 18.0.0 |
| 426 | */ |
| 427 | gboolean |
| 428 | garrow_stream_decoder_consume_bytes(GArrowStreamDecoder *decoder, |
| 429 | GBytes *bytes, |
| 430 | GError **error) |
| 431 | { |
| 432 | auto arrow_decoder = garrow_stream_decoder_get_raw(decoder); |
| 433 | gsize size; |
| 434 | gconstpointer data = g_bytes_get_data(bytes, &size); |
| 435 | return garrow::check(error, |
| 436 | arrow_decoder->Consume(static_cast<const uint8_t *>(data), size), |
| 437 | "[stream-decoder][consume-bytes]"); |
| 438 | } |
| 439 | |
| 440 | /** |
| 441 | * garrow_stream_decoder_consume_buffer: |
nothing calls this directly
no test coverage detected