blob: ff6c0271bd033969048b57ee2cded25222a53da0 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
type batch = {tuples: Concepts.Tuple.t BatFingerTree.t; exhausted: bool}
type t
class type implementation = object
method fetch : int -> (batch, Concepts.Condition.condition) result
end
val make : #implementation -> Handle.protocol
val from : Handle.t -> t Handle.interface option
val require : Handle.t -> (t Handle.interface, Concepts.Condition.condition) result
val fetch : t Handle.interface -> int -> (batch, Concepts.Condition.condition) result
val next : t Handle.interface -> (Concepts.Tuple.t option, Concepts.Condition.condition) result
val exists :
t Handle.interface -> (Concepts.Tuple.t -> bool) -> (bool, Concepts.Condition.condition) result
val drain :
t Handle.interface ->
?limit:int ->
unit ->
(Concepts.Tuple.t BatFingerTree.t, Concepts.Condition.condition) result
|
