packages feed

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 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