Die Verfolgung der Länge, wenn requestBodySourceIO

Question

In Network.HTTP.Conduit verwendet, hat diese Art requestBodySourceIO signature:

Prelude Network.HTTP.Conduit Data.Conduit Control.Monad.Trans.Resource> :t requestBodySourceIO 
requestBodySourceIO 
    :: GHC.Int.Int64 
    -> Source IO Data.ByteString.Internal.ByteString -> RequestBody 

erstes Argument Körperlänge in Bytes. Was ist ein guter Weg, um es die Quelle von ByteString zu übergeben, während die laufende Summe der Bytestring bis jetzt gefüttert verfolgt? Dies wird helfen, am Ende der Anfrage zu bestimmen, wo die Länge, die an sie übergeben wurde, der Gesamtlänge der Bytestring entspricht, die an sie übergeben wurde.

Answer 1

Sie werden eine Quelle für die Bytes haben - rufen Sie diese source. die Quelle zu konstruieren Sie requestBodySourceIO passieren werden, hängen nur ein Leitungssegment, das den Überblick über die Länge hält:

mySource = source =$= processor 0 
    where processor sz = do bs <- await 
          let sz' = sz + BS.length bs 
          ... 
          processor sz' 

Und dann requestBodySourceIO mit mySource nennen.