| 173 | } |
| 174 | |
| 175 | static gssize |
| 176 | garrow_input_stream_skip(GInputStream *stream, |
| 177 | gsize count, |
| 178 | GCancellable *cancellable, |
| 179 | GError **error) |
| 180 | { |
| 181 | if (g_cancellable_set_error_if_cancelled(cancellable, error)) { |
| 182 | return -1; |
| 183 | } |
| 184 | auto arrow_input_stream = garrow_input_stream_get_raw(GARROW_INPUT_STREAM(stream)); |
| 185 | auto status = arrow_input_stream->Advance(count); |
| 186 | if (!garrow_error_check(error, status, "[input-stream][skip]")) { |
| 187 | return -1; |
| 188 | } |
| 189 | return count; |
| 190 | } |
| 191 | |
| 192 | static gboolean |
| 193 | garrow_input_stream_close(GInputStream *stream, GCancellable *cancellable, GError **error) |
nothing calls this directly
no test coverage detected