This implements a SinkSource with keyed changes.
Documentation
data KeyedChanges key delta Source
Ord key => HasSource (KeyedChanges key delta) [delta] delta |
newKeyedChanges :: Ord key => IO (KeyedChanges key delta)Source
sendKeyedChanges :: Ord key => key -> delta -> KeyedChanges key delta -> IO ()Source
deleteKeyedChange :: Ord key => key -> delta -> KeyedChanges key delta -> IO ()Source