promise (empty) → 0.1.0.0

raw patch · 4 files changed

+88/−0 lines, 4 filesdep +asyncdep +basesetup-changed

Dependencies added: async, base

Files

• LICENSE +30/−0
• Setup.hs +2/−0
• promise.cabal +25/−0
• src/Control/Concurrent/Promise.hs +31/−0

@@ -0,0 +1,30 @@+Copyright (c) 2014, Jonathan Fischoff++All rights reserved.++Redistribution and use in source and binary forms, with or without+modification, are permitted provided that the following conditions are met:++    * Redistributions of source code must retain the above copyright+      notice, this list of conditions and the following disclaimer.++    * Redistributions in binary form must reproduce the above+      copyright notice, this list of conditions and the following+      disclaimer in the documentation and/or other materials provided+      with the distribution.++    * Neither the name of Jonathan Fischoff nor the names of other+      contributors may be used to endorse or promote products derived+      from this software without specific prior written permission.++THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS+"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT+LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR+A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT+OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,+SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT+LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,+DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY+THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

@@ -0,0 +1,2 @@+import Distribution.Simple+main = defaultMain

@@ -0,0 +1,25 @@+-- Initial promise.cabal generated by cabal init.  For further +-- documentation, see http://haskell.org/cabal/users-guide/++name:                promise+version:             0.1.0.0+synopsis:            A monadic interface for async+-- description:         +homepage:            http://github.com/jfischoff/promise+license:             BSD3+license-file:        LICENSE+author:              Jonathan Fischoff+maintainer:          jonathangfischoff@gmail.com+-- copyright:           +category:            Concurrency+build-type:          Simple+-- extra-source-files:  +cabal-version:       >=1.10++library+  exposed-modules:     Control.Concurrent.Promise+  -- other-modules:       +  other-extensions:    DeriveFunctor+  build-depends:       base >=4.7 && <4.8, async >=2.0 && <2.1+  hs-source-dirs:      src+  default-language:    Haskell2010

@@ -0,0 +1,31 @@+{-# LANGUAGE DeriveFunctor #-}+module Control.Concurrent.Promise +  ( Promise+  , runPromise+  , liftIO+  ) where+import Control.Concurrent.Async+import Control.Applicative+import Control.Monad++newtype Promise a = Promise { unPromise :: IO (Async a) }+  deriving (Functor)++instance Applicative Promise where+  pure = Promise . async . return+  Promise mf <*> Promise mx = Promise $ do  +      f <- mf+      x <- mx+      (f', x') <- waitBoth f x+      async $ return $ f' x'++instance Monad Promise where+   return = liftIO . return+   Promise m >>= f = Promise $ m >>= wait >>= unPromise . f ++runPromise :: Promise a -> IO a+runPromise = wait <=< unPromise+   +liftIO :: IO a -> Promise a+liftIO = Promise . async+