risingwave_storage::store

Function into_stream_inner

source
fn into_stream_inner<T: IterItem, I: StateStoreIter<T>, O: Send, F: for<'a> Fn(T::ItemRef<'a>) -> StorageResult<O> + Send>(
    iter: I,
    f: F,
) -> impl Stream<Item = Result<O, StorageError>>