Skip to content

Commit

Permalink
more updates from feedback
Browse files Browse the repository at this point in the history
  • Loading branch information
zeroshade committed Oct 22, 2024
1 parent 734b467 commit d75ef0a
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion cpp/src/arrow/c/bridge.cc
Original file line number Diff line number Diff line change
Expand Up @@ -2790,7 +2790,7 @@ struct AsyncProducer {

Future<AsyncRecordBatchGenerator> CreateAsyncDeviceStreamHandler(
struct ArrowAsyncDeviceStreamHandler* handler, internal::Executor* executor,
uint64_t queue_size, const DeviceMemoryMapper mapper) {
uint64_t queue_size, DeviceMemoryMapper mapper) {
auto iterator =
std::make_shared<AsyncRecordBatchIterator>(queue_size, std::move(mapper));
return AsyncRecordBatchIterator::Make(*iterator, handler)
Expand Down
2 changes: 1 addition & 1 deletion cpp/src/arrow/c/bridge.h
Original file line number Diff line number Diff line change
Expand Up @@ -461,7 +461,7 @@ class Executor;
ARROW_EXPORT
Future<AsyncRecordBatchGenerator> CreateAsyncDeviceStreamHandler(
struct ArrowAsyncDeviceStreamHandler* handler, internal::Executor* executor,
uint64_t queue_size = 5, const DeviceMemoryMapper mapper = DefaultDeviceMemoryMapper);
uint64_t queue_size = 5, DeviceMemoryMapper mapper = DefaultDeviceMemoryMapper);

/// \brief Export an AsyncGenerator of record batches using a provided handler
///
Expand Down

0 comments on commit d75ef0a

Please sign in to comment.