Stream.of_array_reverse : 'a array -> 'a Stream.t let unsubscribe = [|1; 2; 3|] |> Stream.of_array_reverse |> Stream.subscribe (fun x -> x |> string_of_int |> print_endline) let _ = print_endline "pass" (* > 3 > 2 > 1 > "pass" *)