Documentation

type ClientMap ht bt a = Map (Async (CurlResponse_ ht bt)) (ClientState a) Source

data ClientState a Source

data RaceState ht bt a Source

csStatus :: forall a a. Lens (ClientState a) (ClientState a) (ClientStatus a) (ClientStatus a) Source

csOptions :: forall a. Lens' (ClientState a) ProviderOptions Source

rsReturnLast :: forall ht bt a. Lens' (RaceState ht bt a) Bool Source

rsHandler :: forall ht bt a. Lens' (RaceState ht bt a) (RacerHandler ht bt a) Source

rsDebug :: forall ht bt a. Lens' (RaceState ht bt a) Bool Source

rsClientMap :: forall ht bt a. Lens' (RaceState ht bt a) (ClientMap ht bt a) Source

rsChecker :: forall ht bt a. Lens' (RaceState ht bt a) (RacerChecker a) Source

extractStatuses :: RaceState ht bt a -> [(Text, ClientStatus a)] Source

makeRaceState :: (CurlHeader ht, CurlBuffer bt, MonadIO m) => Text -> Racer ht bt a -> m (RaceState ht bt a) Source

makeClientMap :: (CurlHeader ht, CurlBuffer bt, MonadIO m) => Text -> [RacerProvider] -> m (ClientMap ht bt a) Source

makeClient :: (CurlHeader ht, CurlBuffer bt, MonadIO m) => Text -> RacerProvider -> m (Async (CurlResponse_ ht bt), ClientState a) Source

performGet :: (CurlHeader ht, CurlBuffer bt) => Text -> ProviderOptions -> IO (CurlResponse_ ht bt) Source

cancelAll :: MonadIO m => [Async a] -> m () Source

cancelRemaining :: (MonadIO m, MonadState (RaceState ht bt a) m) => m () Source

identifier :: Async (CurlResponse_ ht bt) -> ProviderOptions -> Text Source

onlyPending :: ClientMap ht bt a -> ClientMap ht bt a Source

isPending :: ClientStatus a -> Bool Source

markAsSuccessful :: MonadState (RaceState ht bt a) m => Async (CurlResponse_ ht bt) -> a -> m () Source

markAsFailure :: MonadState (RaceState ht bt a) m => Async (CurlResponse_ ht bt) -> a -> m () Source

markAsErrored :: MonadState (RaceState ht bt a) m => Async (CurlResponse_ ht bt) -> SomeException -> m () Source

waitForOne :: (Eq a, MonadIO m, MonadState (RaceState ht bt a) m) => m (Maybe (Async (CurlResponse_ ht bt), a)) Source