Orc.Combinators

Documentation

signal :: Orc ()

cut :: Orc a -> Orc a

Cut executes an orc expression, waits for the first result, and then suppresses the rest, including killing any threads involved in computing the remainder.

onlyUntil :: Orc a -> Orc b -> Orc b

butAfter :: Orc a -> (Float, Orc a) -> Orc a

timeout :: Float -> a -> Orc a -> Orc a

silent :: Orc a -> Orc b

liftList :: MonadPlus list => [a] -> list a

repeating :: Orc a -> Orc a

runChan :: Chan a -> Orc a -> IO ()

sync :: (a -> b -> c) -> Orc a -> Orc b -> Orc c

notBefore :: Orc a -> Float -> Orc a

syncList :: [Orc a] -> Orc [a]

delay :: RealFrac a => a -> Orc ()

Wait for a period of w seconds, then continue processing.

printOrc :: Show a => Orc a -> IO ()

printOrc and prompt uses the Stdinout library to provide basic console input/output in a concurrent setting. runOrc executes an orc expression and prints out the answers eagerly per line.

prompt :: String -> Orc String

putStrLine :: String -> Orc ()

scan :: (a -> s -> s) -> s -> Orc a -> Orc s

(<?>) :: Orc a -> Orc a -> Orc a

count :: Orc a -> Orc (Either a Int)

collect :: Orc a -> Orc [a]

takeOrc :: Int -> Orc a -> Orc a

List-like functions

dropOrc :: Int -> Orc a -> Orc a

zipOrc :: Orc a -> Orc b -> Orc (a, b)

sandbox :: Orc a -> MVar (Maybe a) -> MVar () -> Orc ()

echo :: Int -> MVar (Maybe a) -> MVar () -> Orc a

zipp :: MVar (Maybe a) -> MVar (Maybe b) -> MVar () -> Orc (a, b)

publish :: NFData a => a -> Orc a

Publish is a hyperstrict form of return. It is useful for combining results from multiple val computations, providing a synchronization point.