Function run_observed_stream 

pub async fn run_observed_stream<F, T>(
    observer: &RpcStreamingObserver,
    config: &RpcStreamingConfig,
    stream: F,
) -> Result<T, Status>
where
    F: Future<Output = Result<T, Status>>,

Runs a streaming future with optional timeout and final observation.