diff --git a/src/lib/Qd/Observable/Delta.hs b/src/lib/Qd/Observable/Delta.hs index 2d3394e91e81e5725f418e10b316d4e0b951483e..9c90b0a633f44ffd686c75ca37a772cf114223c6 100644 --- a/src/lib/Qd/Observable/Delta.hs +++ b/src/lib/Qd/Observable/Delta.hs @@ -3,7 +3,7 @@ module Qd.Observable.Delta where import Qd.Observable import Qd.Prelude -import Conduit +--import Conduit import qualified Data.HashMap.Strict as HM import Data.Binary (Binary(..)) import Data.IORef @@ -29,10 +29,9 @@ instance (Eq k, Hashable k, Binary k, Binary v) => Binary (Delta k v) where class Observable (HM.HashMap k v) o => DeltaObservable k v o | o -> k, o -> v where subscribeDelta :: o -> (Delta k v -> IO ()) -> IO SubscriptionHandle - subscribeDelta = undefined - subscribeDeltaC :: o -> ConduitT () (Delta k v) IO () - subscribeDeltaC = undefined - {-# MINIMAL subscribeDelta | subscribeDeltaC #-} + --subscribeDeltaC :: o -> ConduitT () (Delta k v) IO () + --subscribeDeltaC = undefined + --{-# MINIMAL subscribeDelta | subscribeDeltaC #-} observeHashMapDefaultImpl :: forall k v o. (Eq k, Hashable k) => DeltaObservable k v o => o -> (HM.HashMap k v -> IO ()) -> IO SubscriptionHandle observeHashMapDefaultImpl o callback = do