{-# LANGUAGE BangPatterns #-}
{-# LANGUAGE DuplicateRecordFields #-}
module Network.Unexceptional.Chunks
( send
, sendInterruptible
) where
import Control.Concurrent.STM (TVar)
import Data.Bytes.Chunks (Chunks)
import Foreign.C.Error (Errno)
import Network.Socket (Socket)
import qualified Data.Bytes.Chunks as Chunks
import qualified Network.Unexceptional.Bytes as NB
send ::
Socket ->
Chunks ->
IO (Either Errno ())
send :: Socket -> Chunks -> IO (Either Errno ())
send !Socket
s Chunks
cs = Socket -> Bytes -> IO (Either Errno ())
NB.send Socket
s (Chunks -> Bytes
Chunks.concat Chunks
cs)
sendInterruptible ::
TVar Bool ->
Socket ->
Chunks ->
IO (Either Errno ())
sendInterruptible :: TVar Bool -> Socket -> Chunks -> IO (Either Errno ())
sendInterruptible !TVar Bool
interrupt !Socket
s Chunks
cs = TVar Bool -> Socket -> Bytes -> IO (Either Errno ())
NB.sendInterruptible TVar Bool
interrupt Socket
s (Chunks -> Bytes
Chunks.concat Chunks
cs)