LndClient.Watcher

Generic async worker to automate LND gRPC subscriptions. It watches any amount of subscriptions of the same type, and re-subscribes if subscription was not terminated properly. The only way to terminate subscription is to apply unWatch or unWatchUnit function.

Documentation

data Watcher a b

spawnLink :: (Ord a, MonadUnliftIO m, KatipContext m) => LndEnv -> (Maybe (TChan (a, b)) -> LndEnv -> a -> m (Either LndError ())) -> (Watcher a b -> a -> Either LndError b -> m ()) -> m (Watcher a b)

spawnLinkUnit :: (MonadUnliftIO m, KatipContext m) => LndEnv -> (Maybe (TChan ((), b)) -> LndEnv -> m (Either LndError ())) -> (Watcher () b -> Either LndError b -> m ()) -> m (Watcher () b)

watch :: MonadUnliftIO m => Watcher a b -> a -> m ()

watchUnit :: MonadUnliftIO m => Watcher () b -> m ()

unWatch :: MonadUnliftIO m => Watcher a b -> a -> m ()

unWatchUnit :: MonadUnliftIO m => Watcher () b -> m ()

dupLndTChan :: MonadIO m => Watcher a b -> m (TChan (a, b))

delete :: MonadUnliftIO m => Watcher a b -> m ()