Support class to perform either non blockin or blocking receive operation.
| C# | Visual Basic | Visual C++ | J# |
public abstract class NonBlockingReceiveHandler<TData> : IReceiveOperationHandler<TData>
Public MustInherit Class NonBlockingReceiveHandler(Of TData) _ Implements IReceiveOperationHandler(Of TData)
generic<typename TData> public ref class NonBlockingReceiveHandler abstract : IReceiveOperationHandler<TData>
- TData
- Type of data to receive.
| All Members | Constructors | Methods | Properties | ||
| Icon | Member | Description |
|---|---|---|
| NonBlockingReceiveHandler<(Of <(TData>)>)()()() | Initializes a new instance of the NonBlockingReceiveHandler<(Of <(TData>)>) class | |
| Equals(Object) | (Inherited from Object.) | |
| Finalize()()() |
Allows an Object to attempt to free resources and perform other cleanup operations before the Object is reclaimed by garbage collection.
(Inherited from Object.) | |
| GetHashCode()()() |
Serves as a hash function for a particular type.
(Inherited from Object.) | |
| GetType()()() |
Gets the Type of the current instance.
(Inherited from Object.) | |
| MemberwiseClone()()() |
Creates a shallow copy of the current Object.
(Inherited from Object.) | |
| NonBlocking |
Gets or sets whether to perform the operation in a non blocking manner.
| |
| NonBlockingFactor |
Gets or sets the non blocking factor if NonBlocking is true.
For instance if its value is 10 and the receive timeout of the operation is 1 seconds,
The operation will be executed 10 times with intervals of 100 miliseconds between each executions.
| |
| Receive(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64) |
Performs the actual receive operation. Return values allowed are single object or an array of objects.
| |
| ReceiveBatch(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32) |
Performs the actual receive operation. Return values allowed are single object or an array of objects.
| |
| ReceiveBatchBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32) |
Executes receive operation logic in blocking mode
| |
| ReceiveBatchNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int32) |
Executes receive operation logic in non blocking mode
| |
| ReceiveBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64) |
Executes receive operation logic in blocking mode
| |
| ReceiveNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction) |
Executes receive operation logic in non blocking mode
| |
| ToString()()() | (Inherited from Object.) |
| Object | ||
| NonBlockingReceiveHandler<(Of <(TData>)>) | ||
| ExclusiveReadReceiveOperationHandler<(Of <(TData>)>) | ||
| ReadReceiveOperationHandler<(Of <(TData>)>) | ||
| TakeReceiveOperationHandler<(Of <(TData>)>) | ||
