joehillen

{-# LANGUAGE OverloadedStrings, RecordWildCards, LambdaCase #-}

import           Conduit
import           Data.Conduit
import           Data.Conduit.Network
import qualified Data.ByteString.Char8 as BS
import           Data.Conduit.TMChan
import           Text.Printf              (printf)
import           Control.Concurrent.STM
import qualified Data.Map as Map

joehillen

#!/usr/bin/env python
# -*- coding: utf-8 -*-

"""
Written by Joe Hillenbrand <joehillen@gmail.com> 2012

All rights reserved!
"""

import sys

joehillen

#!/usr/bin/env python
# -*- coding: utf-8 -*-

"""
Written by Joe Hillenbrand <joehillen@gmail.com> 2012

All rights reserved!
"""

import string

joehillen

import Control.Concurrent           (forkIO, killThread,
                                     threadDelay, newEmptyMVar,
                                     tryTakeMVar, putMVar)
import Control.Monad                (void, forever)
import Control.Concurrent.STM       (atomically)
import Control.Monad.Trans          (MonadIO(..))
import Control.Monad.Trans.Resource (MonadResource, allocate)
import Data.Conduit                 (GInfConduit, awaitE)

throttle :: (MonadResource m) => Int -> GInfConduit a m a