distributed-process-async 0.2.4.1 → 0.2.6
raw patch · 3 files changed
+12/−18 lines, 3 filesdep +distributed-process-systestdep −HUnitdep ~ansi-terminaldep ~distributed-processdep ~exceptionsPVP ok
version bump matches the API change (PVP)
Dependencies added: distributed-process-systest
Dependencies removed: HUnit
Dependency ranges changed: ansi-terminal, distributed-process, exceptions, network-transport-tcp, time
API changes (from Hackage documentation)
+ Control.Distributed.Process.Async: waitAnySTM :: [Async a] -> IO (Async a, AsyncResult a)
+ Control.Distributed.Process.Async: waitSTM :: Async a -> STM (AsyncResult a)
Files
- distributed-process-async.cabal +9/−8
- src/Control/Distributed/Process/Async.hs +2/−0
- tests/TestAsync.hs +1/−10
distributed-process-async.cabal view
@@ -1,5 +1,5 @@ name: distributed-process-async-version: 0.2.4.1+version: 0.2.6 cabal-version: >=1.8 build-type: Simple license: BSD3@@ -8,7 +8,6 @@ Copyright: Tim Watson 2012 - 2016 Author: Tim Watson Maintainer: Tim Watson <watson.timothy@gmail.com>-Stability: experimental Homepage: http://github.com/haskell-distributed/distributed-process-async Bug-Reports: http://github.com/haskell-distributed/distributed-process-async/issues synopsis: Cloud Haskell Async API@@ -32,7 +31,7 @@ base >= 4.4 && < 5, data-accessor >= 0.2.2.3, distributed-process >= 0.6.1 && < 0.8,- exceptions >= 0.8.2.1 && < 0.9,+ exceptions >= 0.8.2.1 && < 1.0, binary >= 0.6.3.0 && < 0.9, deepseq >= 1.3.0.1 && < 1.5, mtl,@@ -41,7 +40,7 @@ unordered-containers >= 0.2.3.0 && < 0.3, fingertree < 0.2, stm >= 2.4 && < 2.5,- time > 1.4 && < 1.7,+ time >= 1.8.0.2, transformers extensions: CPP InstanceSigs@@ -57,15 +56,17 @@ x-uses-tf: true build-depends: base >= 4.4 && < 5,- ansi-terminal >= 0.5 && < 0.7,+ ansi-terminal >= 0.5 && < 0.9,+ distributed-process, distributed-process-async,- exceptions >= 0.8.2.1 && < 0.9,+ distributed-process-systest >= 0.2.0,+ exceptions >= 0.8.2.1 && < 1.0, network >= 2.5 && < 2.7, network-transport >= 0.4 && < 0.6,- network-transport-tcp >= 0.4 && < 0.7,+ network-transport-tcp >= 0.6 && < 0.9, binary >= 0.6.3.0 && < 0.9, deepseq >= 1.3.0.1 && < 1.5,- HUnit >= 1.2 && < 2,+ -- HUnit >= 1.2 && < 2, stm >= 2.3 && < 2.5, test-framework >= 0.6 && < 0.9, test-framework-hunit,
src/Control/Distributed/Process/Async.hs view
@@ -53,6 +53,8 @@ , waitCheckTimeout -- * STM versions , pollSTM+ , waitSTM+ , waitAnySTM , waitAnyCancel , waitEither , waitEither_
tests/TestAsync.hs view
@@ -4,30 +4,21 @@ module Main where -import Control.Applicative import Control.Concurrent.MVar import Control.Distributed.Process import Control.Distributed.Process.Closure import Control.Distributed.Process.Node import Control.Distributed.Process.Serializable() import Control.Distributed.Process.Async-import Control.Distributed.Process.Extras (Routable(..), Resolvable(..)) import Control.Distributed.Process.SysTest.Utils-import Control.Distributed.Process.Extras.Time-import Control.Distributed.Process.Extras.Timer import Control.Monad (replicateM_) import Data.Binary() import Data.Typeable() import Network.Transport.TCP import qualified Network.Transport as NT -#if ! MIN_VERSION_base(4,6,0)-import Prelude hiding (catch)-#endif- import Test.Framework (Test, testGroup, defaultMain) import Test.Framework.Providers.HUnit (testCase)--- import TestUtils testAsyncPoll :: TestResult (AsyncResult ()) -> Process () testAsyncPoll result = do@@ -228,7 +219,7 @@ -- | Given a @builder@ function, make and run a test suite on a single transport testMain :: (NT.Transport -> IO [Test]) -> IO () testMain builder = do- Right (transport, _) <- createTransportExposeInternals"127.0.0.1" "0" (\sn -> ("127.0.0.1", sn)) defaultTCPParameters+ Right (transport, _) <- createTransportExposeInternals "127.0.0.1" "0" (\sn -> ("127.0.0.1", sn)) defaultTCPParameters testData <- builder transport defaultMain testData