michaelt’s gists

michaelt / chunkX.hs core

Created August 7, 2015 15:37

core for pipes splitAt defined with and without next

michaelt / streamingtest.hs

Last active August 29, 2015 14:27

https://github.com/jwiegley/streaming-tests modified for use with `streaming`

	module Main where

	import qualified Streaming.Prelude as Str
	import qualified System.IO.Streams as IOS
	import Conduit.Simple as S
	import Control.Exception
	import Criterion.Main
	import Data.Conduit as C
	import Data.Conduit.Combinators as C
	import Fusion as F hiding ((&))

michaelt / examples.hs

Last active December 24, 2019 15:36

simple shell-like programs using Data.ByteString.Streaming, following the io-streams tutorial

	-- These examples are based on the tutorial module in the io-streams package

	{-#LANGUAGE OverloadedStrings #-}
	import Streaming
	import Streaming.Prelude (yield, next, each, for, with, subst)
	import qualified Streaming.Prelude as S
	import qualified Data.ByteString.Char8 as B
	import Data.ByteString.Streaming (ByteString)
	import qualified Data.ByteString.Streaming.Char8 as Q
	import System.IO (withFile, IOMode(..))

michaelt / httpstream.hs

Last active March 22, 2024 09:37

A trivial get request which yields a 'byte stream' for manipulation. Here we number the verses of a bible from Project Gutenberg...

	{-#LANGUAGE OverloadedStrings #-}
	import Streaming
	import Streaming.Prelude (each, next, yield)
	import qualified Data.ByteString.Streaming.Char8 as Q
	import qualified Data.ByteString.Char8 as B
	import qualified Streaming.Prelude as S
	import qualified Control.Foldl as L
	import Data.ByteString.Streaming.HTTP -- git clone https://github.com/michaelt/streaming-http
	-- cabal install ./streaming-http
	infixl 5 >>>; (>>>) = flip (.)

michaelt / benchcsv.hs

Last active August 30, 2015 21:54

A benchmark of builder->lazy bytestring versus builder->streaming bytestring (originally it had a different purpose). See results below.

	{-# LANGUAGE OverloadedStrings, PackageImports #-}
	-- \|
	-- Copyright : (c) 2010-2011 Simon Meier
	-- License : BSD3-style (see LICENSE)
	--
	-- Maintainer : Simon Meier <[email protected]>
	-- Stability : experimental
	-- Portability : tested on GHC only
	--
	-- Running example for documentation of Data.ByteString.Lazy.Builder

michaelt / attoparsec notInClass

Created September 10, 2015 01:44

	{-# LANGUAGE OverloadedStrings, BangPatterns #-}
	module Main (main) where

	import Criterion.Main

	import Control.Applicative
	import Data.Attoparsec.ByteString as P
	import Data.Attoparsec.ByteString.Char8 (char8, endOfLine, isDigit_w8)
	import Data.ByteString (ByteString)
	import Data.Word (Word8)

michaelt / hilo.hs

Created October 13, 2015 01:43

Hello world.

	import Streaming
	import qualified Streaming.Prelude as S
	import Control.Monad
	main = do
	S.effects (hilo 30 )
	putStrLn "Right, 30 is correct!"

	hilo :: Int -> Stream (Of Int) IO ()
	hilo n = void $ S.break (== n)
	$ S.chain (\a -> when (a < n) $ putStrLn $ "Too small!")

michaelt / benches.hs

Created November 2, 2015 22:06

https://github.com/jwiegley/streaming-tests modified for use with `streaming` `io-streams` `machines` etc.

	module Main where

	import qualified Streaming.Prelude as Str
	import qualified System.IO.Streams as IOS
	import qualified ListT as ListT
	import Data.Conduit as C
	import Data.Conduit.Combinators as C
	import qualified Data.Machine as M
	import qualified Data.Machine.Runner as M
	import Pipes as P

michaelt / machinesbench.hs

Created November 2, 2015 23:13

Machines benchmark modified to include streaming https://github.com/ekmett/machines/blob/master/benchmarks/Benchmarks.hs

	{-#LANGUAGE NoMonomorphismRestriction #-}
	module Main (main) where

	import Control.Monad (void)
	import Control.Monad.Identity
	import Criterion.Main
	import qualified Data.Conduit as C
	import qualified Data.Conduit.Combinators as CC
	import qualified Data.Conduit.List as C
	import qualified Data.Machine as M

michaelt / call.hs

Last active December 31, 2015 15:34

Call f = Free (Lan f) -- following http://lpaste.net/148140

	{-#LANGUAGE GADTs #-}
	import Control.Monad (ap)

	newtype Free req r = Free {runFree :: Either r (req (Free req r))}
	data Lan f a = forall b. Lan (b -> a) (f b)
	instance Functor (Lan f) where fmap f (Lan xa fx) = Lan (f . xa) fx

	type Call_ req = Free (Lan req)

	call_ :: forall a req . Call req a -> Call_ req a

michaelt michaelt