RiakCluster.UseDelayedConnection(TResult) Method (Func(IRiakConnection, Action, RiakResult(IEnumerable(TResult))), Int32)

RiakClusterUseDelayedConnectionTResult Method (FuncIRiakConnection, Action, RiakResultIEnumerableTResult, Int32)

Executes a delegate function using a IRiakConnection, and returns the results. Can retry up to "retryAttempts" times for NoRetries and ShuttingDown error states. This method is used over UseConnection(FuncIRiakConnection, RiakResult, Int32) to keep a connection open to receive streaming results.

Namespace: RiakClient
Assembly: RiakClient (in RiakClient.dll) Version: f9bb17a3f8ff6940b88010a52f202e3d55fe25c5

Syntax

Copy

public override RiakResult<IEnumerable<TResult>> UseDelayedConnection<TResult>(
	Func<IRiakConnection, Action, RiakResult<IEnumerable<TResult>>> useFun,
	int retryAttempts
)
where TResult : RiakResult

abstract UseDelayedConnection : 
        useFun : Func<IRiakConnection, Action, RiakResult<IEnumerable<'TResult>>> * 
        retryAttempts : int -> RiakResult<IEnumerable<'TResult>>  when 'TResult : RiakResult
override UseDelayedConnection : 
        useFun : Func<IRiakConnection, Action, RiakResult<IEnumerable<'TResult>>> * 
        retryAttempts : int -> RiakResult<IEnumerable<'TResult>>  when 'TResult : RiakResult

Parameters

useFun: Type: SystemFuncIRiakConnection, Action, RiakResultIEnumerableTResult
The delegate function to execute. Takes an IRiakConnection and an Action continuation as input, and returns a RiakResultTResult containing an IEnumerableT as the results of the operation.
retryAttempts: Type: SystemInt32
The number of times to retry an operation.

Type Parameters

TResult: The type of the result from the useFun parameter.

Return Value

Type: RiakResultIEnumerableTResult
The results of the useFun delegate.

Implements

IRiakEndPointUseDelayedConnectionTResult(FuncIRiakConnection, Action, RiakResultIEnumerableTResult, Int32)

Reference

RiakCluster Class

UseDelayedConnection Overload

RiakClient Namespace