( Interaction(..)
, InteractionState(..)
, InteractionQueue
- , GetBodyRequest(..)
+ , ReceiveBodyRequest(..)
, newInteractionQueue
, newInteraction
, itrExpectedContinue ∷ !(Maybe Bool)
, itrReqBodyLength ∷ !(Maybe RequestBodyLength)
- , itrGetBodyRequest ∷ !(TMVar GetBodyRequest)
- , itrGotBody ∷ !(TMVar Strict.ByteString)
+ , itrReceiveBodyReq ∷ !(TMVar ReceiveBodyRequest)
+ , itrReceivedBody ∷ !(TMVar Strict.ByteString)
, itrResponse ∷ !(TVar Response)
, itrWillChunkBody ∷ !(TVar Bool)
-- initial state.
data InteractionState
= ExaminingRequest
- | GettingBody
+ | ReceivingBody
| DecidingHeader
- | DecidingBody
+ | SendingBody
| Done
deriving (Show, Eq, Ord, Enum)
type InteractionQueue = TVar (Seq Interaction)
-data GetBodyRequest
- = GetBody !Int -- ^ Maximum number of bytes.
+data ReceiveBodyRequest
+ = ReceiveBody !Int -- ^ Maximum number of octets to receive.
| WasteAll
deriving (Show, Eq)
, resHeaders = (∅)
}
- getBodyRequest ← newEmptyTMVarIO
- gotBody ← newEmptyTMVarIO
+ receiveBodyReq ← newEmptyTMVarIO
+ receivedBody ← newEmptyTMVarIO
response ← newTVarIO res
willChunkBody ← newTVarIO False
, itrExpectedContinue = arExpectedContinue ar
, itrReqBodyLength = arReqBodyLength ar
- , itrGetBodyRequest = getBodyRequest
- , itrGotBody = gotBody
+ , itrReceiveBodyReq = receiveBodyReq
+ , itrReceivedBody = receivedBody
, itrResponse = response
, itrWillChunkBody = willChunkBody