Method WithStreamProcessor

Namespace

Neo4j.Driver

Assembly

Neo4j.Driver.dll

WithStreamProcessor<TResult>(Func<IAsyncEnumerable<TIn>, Task<TResult>>)

Specifies a stream processor that will process the System.Collections.Generic.IAsyncEnumerable<T> that results from a query, and return the value that will be given as the result of the query.

IReducedExecutableQuery<TResult> WithStreamProcessor<TResult>(Func<IAsyncEnumerable<TIn>, Task<TResult>> streamProcessor)

Parameters

streamProcessor Func<IAsyncEnumerable<TIn>, Task<TResult>>

An asynchronous method that will process the supplied asynchronous stream of records.

Returns

IReducedExecutableQuery<TResult>

The same instance which can only be used to execute the query.

Type Parameters

TResult

The type of the return value from streamProcessor.