module Network.Monad.Transfer where
import qualified Network.Stream as Stream
import Control.Monad.IO.Class (MonadIO(liftIO), )
import qualified Control.Monad.Exception.Asynchronous as Async
import qualified Control.Monad.Exception.Synchronous as Sync
import Control.Applicative (WrappedMonad(WrapMonad), unwrapMonad, )
import Data.Monoid (Monoid, )
type SyncExceptional m =
Sync.ExceptionalT Stream.ConnError m
type AsyncExceptional m =
Async.ExceptionalT Stream.ConnError m
data T m body =
Cons {
readLine :: AsyncExceptional m body,
readBlock :: Int -> AsyncExceptional m body,
writeBlock :: body -> SyncExceptional m ()
}
liftIOSync :: MonadIO io =>
IO (Stream.Result a) -> SyncExceptional io a
liftIOSync m =
Sync.fromEitherT $ liftIO m
liftIOAsync :: (MonadIO io, Monoid a) =>
IO (Stream.Result a) -> AsyncExceptional io a
liftIOAsync =
Async.mapExceptionalT unwrapMonad .
Async.fromSynchronousMonoidT .
Sync.mapExceptionalT WrapMonad .
liftIOSync