ignite-3 icon indicating copy to clipboard operation
ignite-3 copied to clipboard

IGNITE-21490 .NET: Add DataStreamer data removal

Open ptupitsyn opened this issue 2 years ago • 0 comments

Change DataStreamer API to allow data removal:

  • IDataStreamerTarget now accepts IAsyncEnumerable<DataStreamerItem<T>>
  • Simplified overload accepts IAsyncEnumerable<T> as it was before
  • DataStreamerItem<T> is a struct record (no allocations), accepts data item and DataStreamerOperationType enum
  • DataStreamerItem factory class added to simplify generics (similar to standard library KeyValuePair.Create:
    • Constructor: new DataStreamerItem<MyEntityClass<Guid>>(entity) - entity type must be specified
    • Factory: DataStreamerItem.Create(entity) - entity type is inferred

ptupitsyn avatar Apr 05 '24 08:04 ptupitsyn