Function resp_to_stream

pub fn resp_to_stream(
    resp_stream: impl Future<Output = Result<Response<Streaming<AppendRowsResponse>>, Status>> + 'static + Send,
) -> impl Stream<Item = Result<(), SinkError>>