Performs single take operation using Take<(Of <(T>)>)(T, ITransaction, Int64)

C# | Visual Basic | Visual C++ | J# |
public class TakeReceiveOperationHandler<TData> : NonBlockingReceiveHandler<TData>
Public Class TakeReceiveOperationHandler(Of TData) _ Inherits NonBlockingReceiveHandler(Of TData)
generic<typename TData> public ref class TakeReceiveOperationHandler : public NonBlockingReceiveHandler<TData>

- TData
- Type of data to receive.

All Members | Constructors | Methods | Properties | ||
Icon | Member | Description |
---|---|---|
![]() | TakeReceiveOperationHandler<(Of <(TData>)>)()()() | Initializes a new instance of the TakeReceiveOperationHandler<(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.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) |
![]() | 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.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) |
![]() | Receive(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64) |
Performs the actual receive operation. Return values allowed are single object or an array of objects.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) |
![]() | ReceiveBatch(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32) |
Performs the actual receive operation. Return values allowed are single object or an array of objects.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) |
![]() | ReceiveBatchBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32) |
Executes receive operation logic in blocking mode
(Overrides NonBlockingReceiveHandler<(Of <(TData>)>).ReceiveBatchBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32).) |
![]() | ReceiveBatchNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int32) |
Executes receive operation logic in non blocking mode
(Overrides NonBlockingReceiveHandler<(Of <(TData>)>).ReceiveBatchNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int32).) |
![]() | ReceiveBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64) |
Executes receive operation logic in blocking mode
(Overrides NonBlockingReceiveHandler<(Of <(TData>)>).ReceiveBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64).) |
![]() | ReceiveNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction) |
Executes receive operation logic in non blocking mode
(Overrides NonBlockingReceiveHandler<(Of <(TData>)>).ReceiveNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction).) |
![]() | ToString()()() | (Inherited from Object.) |

Object | ||
![]() | NonBlockingReceiveHandler<(Of <(TData>)>) | |
![]() | TakeReceiveOperationHandler<(Of <(TData>)>) |