fonction fourchus pour Conduit

Question

Je veux calculer hachage du corps post http et l'analyser en même temps lors de la réception, donc je besoin d'une fonction comme ceci:

unionSinks :: Monad m => Consumer a m r1 -> Consumer a m r2 -> Consumer a m (r1, r2) 
unionSinks = ... 

sinkBody :: Monad m => FromJSON v => Consumer ByteString m (Digest SHA1, v) 
sinkBody = sinkHash `unionSinks` sinkParser json 

Lorsque j'ai développé L'ajout d'image je passthroughSink dans la même manière . Mais je n'ai pas besoin du résultat du conduit, qui enregistre l'image dans un fichier, dans ce cas.

Généralement, je sais comment implémenter une fourche en utilisant des choses ressemblant à MVar, mais je ne suis pas sûr que ce soit une solution optimale.

Answer 1

En effet vous avez besoin ZipSink (ou plus général ZipConduit):

import Control.Applicative 
import Data.Conduit 

unionSinks :: (Monad m) => Sink a m r1 -> Sink a m r2 -> Sink a m (r1, r2) 
unionSinks s1 s2 = getZipSink ((,) <$> ZipSink s1 <*> ZipSink s2)