Up

Module Pipe_zipper = Pipe_zipper

Signature

type 'a t
val create : ?max_history:int -> (unit -> 'a Async.Std.Pipe.Reader.t Async.Std.Deferred.t) -> 'a t
val zip : 'a t -> [
| `next
| `prev
] -> int -> 'a Core.Std.Or_error.t Async.Std.Deferred.t
val find : 'a t -> f:('a -> bool) -> 'a Core.Std.Or_error.t Async.Std.Deferred.t
val find_rev : 'a t -> f:('a -> bool) -> 'a Core.Std.Or_error.t Async.Std.Deferred.t
val find_first_larger_or_equal : 'a t -> compare_with_target:('a -> int) -> 'a Core.Std.Or_error.t Async.Std.Deferred.t