ignite-3
ignite-3 copied to clipboard
IGNITE-21490 .NET: Add DataStreamer data removal
Change DataStreamer API to allow data removal:
-
IDataStreamerTargetnow acceptsIAsyncEnumerable<DataStreamerItem<T>> - Simplified overload accepts
IAsyncEnumerable<T>as it was before -
DataStreamerItem<T>is a struct record (no allocations), accepts data item andDataStreamerOperationTypeenum -
DataStreamerItemfactory class added to simplify generics (similar to standard libraryKeyValuePair.Create:- Constructor:
new DataStreamerItem<MyEntityClass<Guid>>(entity)- entity type must be specified - Factory:
DataStreamerItem.Create(entity)- entity type is inferred
- Constructor: