@@ -479,12 +479,7 @@ newtype ToEventRawException = ToEventRawException CInt
479 deriving (Show, Typeable)
479 deriving (Show, Typeable)
480instance Exception ToEventRawException
480instance Exception ToEventRawException
482−decode :: MonadResource m => B.ByteString
482+decode :: MonadResource m => B.ByteString -> Producer m Event
483−#if MIN_VERSION_conduit(1, 0, 0)
488decode bs | B8.null bs = return ()
483decode bs | B8.null bs = return ()
489decode bs =
484decode bs =
490 bracketP alloc cleanup (runParser . fst)
485 bracketP alloc cleanup (runParser . fst)
@@ -526,12 +521,7 @@ openFile file rawOpenFlags openMode = do
526 then withCString openMode $ \openMode' -> c_fdopen fd openMode'
521 then withCString openMode $ \openMode' -> c_fdopen fd openMode'
527 else return nullPtr
522 else return nullPtr
529−decodeFile :: MonadResource m => FilePath
524+decodeFile :: MonadResource m => FilePath -> Producer m Event
530−#if MIN_VERSION_conduit(1, 0, 0)
535decodeFile file =
525decodeFile file =
536 bracketP alloc cleanup (runParser . fst)
526 bracketP alloc cleanup (runParser . fst)
@@ -559,12 +549,7 @@ decodeFile file =
559 c_yaml_parser_delete ptr
549 c_yaml_parser_delete ptr
562−runParser :: MonadResource m => Parser
552+runParser :: MonadResource m => Parser -> Producer m Event
563−#if MIN_VERSION_conduit(1, 0, 0)
568runParser parser = do
553runParser parser = do
569 e <- liftIO $ parserParseOne' parser
554 e <- liftIO $ parserParseOne' parser
570 case e of
555 case e of
@@ -588,12 +573,7 @@ parserParseOne' parser = allocaBytes eventSize $ \er -> do
588 return $ Left $ YamlParseException problem context problemMark
573 return $ Left $ YamlParseException problem context problemMark
589 else Right <$> getEvent er
574 else Right <$> getEvent er
591−encode :: MonadResource m
592−#if MIN_VERSION_conduit(1, 0, 0)
593− => Consumer Event m ByteString
576+encode :: MonadResource m => Consumer Event m ByteString
595− => GSink Event m ByteString
598 runEmitter alloc close
578 runEmitter alloc close
@@ -610,11 +590,7 @@ encode =
611encodeFile :: MonadResource m
591encodeFile :: MonadResource m
612 => FilePath
592 => FilePath
613−#if MIN_VERSION_conduit(1, 0, 0)
614 -> Consumer Event m ()
593 -> Consumer Event m ()
618encodeFile filePath =
594encodeFile filePath =
619 bracketP getFile c_fclose $ \file -> runEmitter (alloc file) (\u _ -> return u)
595 bracketP getFile c_fclose $ \file -> runEmitter (alloc file) (\u _ -> return u)
@@ -628,13 +604,8 @@ encodeFile filePath =
629runEmitter :: MonadResource m
605runEmitter :: MonadResource m
630 => (Emitter -> IO a) -- ^ alloc
606 => (Emitter -> IO a) -- ^ alloc
631−#if MIN_VERSION_conduit(1, 0, 0)
632 -> (() -> a -> IO b) -- ^ close
607 -> (() -> a -> IO b) -- ^ close
633 -> Consumer Event m b
608 -> Consumer Event m b
635− -> (u -> a -> IO b) -- ^ close
636− -> Pipe l Event o u m b
638runEmitter allocI closeI =
609runEmitter allocI closeI =
639 bracketP alloc cleanup go
610 bracketP alloc cleanup go
@@ -654,11 +625,7 @@ runEmitter allocI closeI =
654 go (emitter, a) =
625 go (emitter, a) =
657−#if MIN_VERSION_conduit(1, 0, 0)
658 loop = await >>= maybe (close ()) push
628 loop = await >>= maybe (close ()) push
660− loop = awaitE >>= either close push
663 push e = do
630 push e = do
664 _ <- liftIO $ toEventRaw e $ c_yaml_emitter_emit emitter
631 _ <- liftIO $ toEventRaw e $ c_yaml_emitter_emit emitter