Method Read

c_glib/arrow-glib/input-stream.cpp:774–789

    }

    arrow::Result<int64_t>
    Read(int64_t n_bytes, void *out) override
    {
      std::lock_guard<std::mutex> guard(lock_);
      GError *error = NULL;
      gsize n_read_bytes = 0;
      auto success =
        g_input_stream_read_all(input_stream_, out, n_bytes, &n_read_bytes, NULL, &error);
      if (success) {
        return n_read_bytes;
      } else {
        return garrow_error_to_status(error,
                                      arrow::StatusCode::IOError,
                                      "[gio-input-stream][read]");
      }
    }

    arrow::Result<int64_t>
    ReadAt(int64_t position, int64_t n_bytes, void *out) override