Search Results for

Show / Hide Table of Contents

# Class StreamVisitor<TK, TV>

Convenience adapter to visit every key-value tuple in the stream. Note that the visitor does not update the cache.

##### Inheritance

System.Object
StreamVisitor<TK, TV>

##### Implements

IStreamReceiver<TK, TV>

###### Namespace: Apache.Ignite.Core.Datastream

###### Assembly: Apache.Ignite.Core.dll

##### Syntax

    public sealed class StreamVisitor<TK, TV> : object, IStreamReceiver<TK, TV>

##### Type Parameters

Name | Description
--- | ---
TK | The type of the cache key.
TV | The type of the cache value.

### Constructors

#### StreamVisitor(Action<ICache<TK, TV>, ICacheEntry<TK, TV>>)

Initializes a new instance of the StreamVisitor<TK, TV> class.

##### Declaration

    public StreamVisitor(Action<ICache<TK, TV>, ICacheEntry<TK, TV>> action)

##### Parameters

Type | Name | Description
--- | --- | ---
Action<ICache<TK, TV>, ICacheEntry<TK, TV>> | action | The action to be called on each stream entry.

### Methods

#### Receive(ICache<TK, TV>, ICollection<ICacheEntry<TK, TV>>)

Updates cache with batch of entries.

##### Declaration

    public void Receive(ICache<TK, TV> cache, ICollection<ICacheEntry<TK, TV>> entries)

##### Parameters

Type | Name | Description
--- | --- | ---
ICache<TK, TV> | cache | Cache.
ICollection<ICacheEntry<TK, TV>> | entries | Entries.

### Implements

IStreamReceiver<TK, TV>