Documentation

allEvents :: IsStream t => t IO (Device, Event) Source #

filteredEvents :: IsStream t => (Device -> Bool) -> t IO (Device, Event) Source #

readEvents :: IsStream t => Device -> t IO Event Source #

readEventsMany :: IsStream t => AsyncT IO Device -> t IO (Device, Event) Source #

makeDevices :: (Functor (t IO), IsStream t) => t IO RawFilePath -> t IO Device Source #

existingDevicePaths :: (IsStream t, MonadIO (t IO)) => t IO RawFilePath Source #

newDevicePaths :: (MonadIO (t IO), IsStream t) => t IO RawFilePath Source #

handleBoolRetry :: Exception e => (e -> Bool) -> Int -> IO a -> IO a Source #

unfoldrM' :: (IsStream t, MonadAsync m) => m (Maybe a) -> t m a Source #

lsFiles :: RawFilePath -> IO [RawFilePath] Source #