Function record_stream_send 

pub async fn record_stream_send<F, T>(
    observer: &RpcStreamingObserver,
    send: F,
) -> Result<T, Status>
where
    F: Future<Output = Result<T, Status>>,

Runs one streaming send operation with send observation.