Stream.of_item : 'a -> 'a Stream.t let unsubscribe = "hello" |> Stream.of_item |> Stream.subscribe print_endline let _ = print_endline "pass" (* > "hello" > "pass" *)