Safe Haskell	None
Language	Haskell2010

Servant.HttpStreams.Internal

Synopsis

data ClientEnv = ClientEnv {
- baseUrl :: BaseUrl
- connection :: Connection
}
mkClientEnv :: BaseUrl -> Connection -> ClientEnv
withClientEnvIO :: BaseUrl -> (ClientEnv -> IO r) -> IO r
client :: HasClient ClientM api => Proxy api -> Client ClientM api
hoistClient :: HasClient ClientM api => Proxy api -> (forall a. m a -> n a) -> Client m api -> Client n api
newtype ClientM a = ClientM {
- unClientM :: ReaderT ClientEnv (ExceptT ClientError (Codensity IO)) a
}
runClientM :: NFData a => ClientM a -> ClientEnv -> IO (Either ClientError a)
withClientM :: ClientM a -> ClientEnv -> (Either ClientError a -> IO b) -> IO b
performRequest :: Maybe [Status] -> Request -> ClientM Response
performWithStreamingRequest :: Request -> (StreamingResponse -> IO a) -> ClientM a
mkFailureResponse :: BaseUrl -> Request -> ResponseF ByteString -> ClientError
clientResponseToResponse :: Response -> body -> ResponseF body
requestToClientRequest :: BaseUrl -> Request -> (Request, OutputStream Builder -> IO ())
catchConnectionError :: IO a -> IO (Either ClientError a)
fromInputStream :: InputStream b -> SourceT IO b
toOutputStream :: SourceT IO ByteString -> OutputStream Builder -> IO ()

Documentation

data ClientEnv Source #

The environment in which a request is run.

ClientEnv carries an open connection. See withClientEnvIO.

Constructors

ClientEnv
Fields baseUrl :: BaseUrl connection :: Connection

Instances

Instances details

MonadReader ClientEnv ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods ask :: ClientM ClientEnv # local :: (ClientEnv -> ClientEnv) -> ClientM a -> ClientM a # reader :: (ClientEnv -> a) -> ClientM a #

mkClientEnv :: BaseUrl -> Connection -> ClientEnv Source #

ClientEnv smart constructor.

withClientEnvIO :: BaseUrl -> (ClientEnv -> IO r) -> IO r Source #

Open a connection to BaseUrl.

client :: HasClient ClientM api => Proxy api -> Client ClientM api Source #

Generates a set of client functions for an API.

Example:

type API = Capture "no" Int :> Get '[JSON] Int
       :<|> Get '[JSON] [Bool]

api :: Proxy API
api = Proxy

getInt :: Int -> ClientM Int
getBools :: ClientM [Bool]
getInt :<|> getBools = client api

hoistClient :: HasClient ClientM api => Proxy api -> (forall a. m a -> n a) -> Client m api -> Client n api Source #

Change the monad the client functions live in, by supplying a conversion function (a natural transformation to be precise).

For example, assuming you have some manager :: Manager and baseurl :: BaseUrl around:

type API = Get '[JSON] Int :<|> Capture "n" Int :> Post '[JSON] Int
api :: Proxy API
api = Proxy
getInt :: IO Int
postInt :: Int -> IO Int
getInt :<|> postInt = hoistClient api (flip runClientM cenv) (client api)
  where cenv = mkClientEnv manager baseurl

newtype ClientM a Source #

ClientM is the monad in which client functions run. Contains the Manager and BaseUrl used for requests in the reader environment.

Constructors

ClientM
Fields unClientM :: ReaderT ClientEnv (ExceptT ClientError (Codensity IO)) a

Instances

Instances details

Monad ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods (>>=) :: ClientM a -> (a -> ClientM b) -> ClientM b # (>>) :: ClientM a -> ClientM b -> ClientM b # return :: a -> ClientM a #
Functor ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods fmap :: (a -> b) -> ClientM a -> ClientM b # (<$) :: a -> ClientM b -> ClientM a #
Applicative ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods pure :: a -> ClientM a # (<>) :: ClientM (a -> b) -> ClientM a -> ClientM b # liftA2 :: (a -> b -> c) -> ClientM a -> ClientM b -> ClientM c # (>) :: ClientM a -> ClientM b -> ClientM b # (<*) :: ClientM a -> ClientM b -> ClientM a #
MonadIO ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods liftIO :: IO a -> ClientM a #
Alt ClientM Source #	Try clients in order, last error is preserved.
Instance details Defined in Servant.HttpStreams.Internal Methods (<!>) :: ClientM a -> ClientM a -> ClientM a # some :: Applicative ClientM => ClientM a -> ClientM [a] # many :: Applicative ClientM => ClientM a -> ClientM [a] #
RunClient ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods runRequestAcceptStatus :: Maybe [Status] -> Request -> ClientM Response # throwClientError :: ClientError -> ClientM a #
RunStreamingClient ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods withStreamingRequest :: Request -> (StreamingResponse -> IO a) -> ClientM a #
MonadReader ClientEnv ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods ask :: ClientM ClientEnv # local :: (ClientEnv -> ClientEnv) -> ClientM a -> ClientM a # reader :: (ClientEnv -> a) -> ClientM a #
MonadBase IO ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods liftBase :: IO α -> ClientM α #
MonadError ClientError ClientM Source #
Instance details Defined in Servant.HttpStreams.Internal Methods throwError :: ClientError -> ClientM a # catchError :: ClientM a -> (ClientError -> ClientM a) -> ClientM a #
Generic (ClientM a) Source #
Instance details Defined in Servant.HttpStreams.Internal Associated Types type Rep (ClientM a) :: Type -> Type # Methods from :: ClientM a -> Rep (ClientM a) x # to :: Rep (ClientM a) x -> ClientM a #
type Rep (ClientM a) Source #
Instance details Defined in Servant.HttpStreams.Internal type Rep (ClientM a) = D1 ('MetaData "ClientM" "Servant.HttpStreams.Internal" "servant-http-streams-0.18.4-AzajkAp7OMqIzEwa30Fthi" 'True) (C1 ('MetaCons "ClientM" 'PrefixI 'True) (S1 ('MetaSel ('Just "unClientM") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ReaderT ClientEnv (ExceptT ClientError (Codensity IO)) a))))

runClientM :: NFData a => ClientM a -> ClientEnv -> IO (Either ClientError a) Source #

withClientM :: ClientM a -> ClientEnv -> (Either ClientError a -> IO b) -> IO b Source #

performRequest :: Maybe [Status] -> Request -> ClientM Response Source #

performWithStreamingRequest :: Request -> (StreamingResponse -> IO a) -> ClientM a Source #

mkFailureResponse :: BaseUrl -> Request -> ResponseF ByteString -> ClientError Source #

clientResponseToResponse :: Response -> body -> ResponseF body Source #

requestToClientRequest :: BaseUrl -> Request -> (Request, OutputStream Builder -> IO ()) Source #

catchConnectionError :: IO a -> IO (Either ClientError a) Source #

fromInputStream :: InputStream b -> SourceT IO b Source #

toOutputStream :: SourceT IO ByteString -> OutputStream Builder -> IO () Source #