icydb-core 0.67.0

IcyDB — A type-safe, embedded ORM and schema system for the Internet Computer
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//! Module: db::executor::terminal::ranking::take
//! Responsibility: module-local ownership and contracts for db::executor::terminal::ranking::take.
//! Does not own: cross-module orchestration outside this module.
//! Boundary: exposes this module API while keeping implementation details internal.

use crate::{
    db::{
        PersistedRow,
        executor::{
            ExecutablePlan, pipeline::contracts::LoadExecutor,
            terminal::ranking::RankingTerminalBoundaryRequest,
        },
        response::EntityResponse,
    },
    error::InternalError,
    traits::EntityValue,
};

impl<E> LoadExecutor<E>
where
    E: PersistedRow + EntityValue,
{
    /// Execute one `take(k)` terminal over the canonical load response.
    pub(in crate::db) fn take(
        &self,
        plan: ExecutablePlan<E>,
        take_count: u32,
    ) -> Result<EntityResponse<E>, InternalError> {
        self.execute_ranking_terminal_boundary(
            plan.into_prepared_load_plan(),
            RankingTerminalBoundaryRequest::Take { take_count },
        )?
        .into_rows()
    }
}