Method Close

cpp/src/arrow/io/concurrency.h:94–97

class InputStreamConcurrencyWrapper : public InputStream {
 public:
  Status Close() final {
    auto guard = lock_.exclusive_guard();
    return derived()->DoClose();
  }

  Status Abort() final {
    auto guard = lock_.exclusive_guard();