diff --git a/Sources/CassandraClient/Session.swift b/Sources/CassandraClient/Session.swift index a01e0da..9acc54b 100644 --- a/Sources/CassandraClient/Session.swift +++ b/Sources/CassandraClient/Session.swift @@ -342,7 +342,7 @@ extension CassandraClient { let eventLoop = eventLoop ?? self.eventLoopGroup.next() do { - try statement.setPagingSize(pageSize) + try statement.setPagingSize(Int(pageSize)) } catch { return eventLoop.makeFailedFuture(error) } @@ -559,7 +559,7 @@ extension CassandraClient.Session { ) async throws -> CassandraClient.PaginatedRows { - try statement.setPagingSize(pageSize) + try statement.setPagingSize(Int(pageSize)) return CassandraClient.PaginatedRows(session: self, statement: statement, logger: logger) } diff --git a/Sources/CassandraClient/Statement.swift b/Sources/CassandraClient/Statement.swift index 3281773..8cc9f6f 100644 --- a/Sources/CassandraClient/Statement.swift +++ b/Sources/CassandraClient/Statement.swift @@ -146,8 +146,9 @@ extension CassandraClient { return cass_statement_bind_collection(self.rawPointer, index, collection) } - func setPagingSize(_ pagingSize: Int32) throws { - try checkResult { cass_statement_set_paging_size(self.rawPointer, pagingSize) } + /// Sets the paging size of the returned paginated results. + public func setPagingSize(_ pagingSize: Int) throws { + try checkResult { cass_statement_set_paging_size(self.rawPointer, Int32(clamping: pagingSize)) } } /// Sets the starting page of the returned paginated results.