@@ -6,6 +6,7 @@ module Control.Distributed.Process.Internal.Closure.CP
66 , cpUnlink
77 , cpSend
88 , cpExpect
9+ , cpNewChan
910 -- * @Closure (Process a)@ as a not-quite-monad
1011 , cpReturn
1112 , cpBind
@@ -32,12 +33,15 @@ import Control.Distributed.Process.Internal.Types
3233 , ProcessId
3334 , LocalNode(remoteTable)
3435 , procMsg
36+ , SendPort
37+ , ReceivePort
3538 )
3639import Control.Distributed.Process.Internal.Primitives
3740 ( link
3841 , unlink
3942 , send
4043 , expect
44+ , newChan
4145 )
4246import Control.Distributed.Process.Internal.Closure.TH (remotable, mkStatic)
4347import Control.Distributed.Process.Internal.MessageT (getLocalNode)
@@ -83,6 +87,9 @@ sendDict SerializableDict = send
8387expectDict :: SerializableDict a -> Process a
8488expectDict SerializableDict = expect
8589
90+newChanDict :: SerializableDict a -> Process (SendPort a, ReceivePort a)
91+newChanDict SerializableDict = newChan
92+
8693---- Serialization dictionaries ------------------------------------------------
8794
8895-- | Specialized serialization dictionary required in 'cpBind'
@@ -141,6 +148,7 @@ remotable [ -- Monadic operations
141148 -- Explicit dictionaries
142149 , 'sendDict
143150 , 'expectDict
151+ , 'newChanDict
144152 -- Serialization dictionaries
145153 , 'sdictBind
146154 -- Specialized processes
@@ -175,6 +183,12 @@ cpSend dict pid = Closure decoder (encode pid)
175183cpExpect :: Typeable a => Static (SerializableDict a) -> Closure (Process a)
176184cpExpect dict = staticClosure ($(mkStatic 'expectDict) `staticApply` dict)
177185
186+-- | Closure version of 'newChan'
187+cpNewChan :: Typeable a
188+ => Static (SerializableDict a)
189+ -> Closure (Process (SendPort a, ReceivePort a))
190+cpNewChan dict = staticClosure ($(mkStatic 'newChanDict) `staticApply` dict)
191+
178192--------------------------------------------------------------------------------
179193-- (Closure . Process) as a not-quite-monad --
180194--------------------------------------------------------------------------------