Support class to perform receive operations with or without memory only search.
If configured to use memory only search, the read/take operation will use MemoryOnlySearch / MemoryOnlySearch accordingly.
![](../icons/collapse_all.gif)
C# | Visual Basic | Visual C++ | J# |
public abstract class MemoryOnlySearchReceiveHandler<TData> : NonBlockingReceiveHandler<TData>
Public MustInherit Class MemoryOnlySearchReceiveHandler(Of TData) _ Inherits NonBlockingReceiveHandler(Of TData)
generic<typename TData> public ref class MemoryOnlySearchReceiveHandler abstract : public NonBlockingReceiveHandler<TData>
![](../icons/collapse_all.gif)
- TData
- Type of data to receive
![](../icons/collapse_all.gif)
All Members | Constructors | Methods | Properties | ||
Icon | Member | Description |
---|---|---|
![]() | MemoryOnlySearchReceiveHandler<(Of <(<'TData>)>)>()()()() | Initializes a new instance of the MemoryOnlySearchReceiveHandler<(Of <(<'TData>)>)> class |
![]() | Equals(Object) |
Determines whether the specified Object is equal to the current 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
(Inherited from NonBlockingReceiveHandler<(Of <(<'TData>)>)>.) |
![]() | ReceiveBatchNonBlocking(IQuery<(Of <<'(TData>)>>), ISpaceProxy, ITransaction, Int32) |
Executes receive operation logic in non blocking mode
(Inherited from NonBlockingReceiveHandler<(Of <(<'TData>)>)>.) |
![]() | ReceiveBlocking(IQuery<(Of <<'(TData>)>>), ISpaceProxy, ITransaction, Int64) |
Executes receive operation logic in blocking mode
(Inherited from NonBlockingReceiveHandler<(Of <(<'TData>)>)>.) |
![]() | ReceiveNonBlocking(IQuery<(Of <<'(TData>)>>), ISpaceProxy, ITransaction) |
Executes receive operation logic in non blocking mode
(Inherited from NonBlockingReceiveHandler<(Of <(<'TData>)>)>.) |
![]() | ToString()()()() |
Returns a String that represents the current Object.
(Inherited from Object.) |
![]() | UseMemoryOnlySearch |
Allows to configure the take/read operation to be performed in a memory only search manner.
If set to true, will use MemoryOnlySearch / MemoryOnlySearch as read/take modifiers.
|
![](../icons/collapse_all.gif)
Object | |||
![]() | NonBlockingReceiveHandler<(Of <(<'TData>)>)> | ||
![]() | MemoryOnlySearchReceiveHandler<(Of <(<'TData>)>)> | ||
![]() | FifoGroupingReceiveHandler<(Of <(<'TData>)>)> | ||
![]() | ReadReceiveOperationHandler<(Of <(<'TData>)>)> |