Merge pull request #8 from fsprojects/fix-5

remove Agent.fs

Author: dsyme

src/FSharp.Control.AsyncSeq/Agent.fs

@@ -411,7 +411,7 @@ module AsyncSeq =
   /// sequence specified as the input. When accessing the resulting sequence
   /// multiple times, the input will still be evaluated only once
   let rec cache (input : AsyncSeq<'T>) = 
-    let agent = Agent<AsyncReplyChannel<_>>.Start(fun agent -> async {
+    let agent = MailboxProcessor<AsyncReplyChannel<_>>.Start(fun agent -> async {
       let! (repl:AsyncReplyChannel<AsyncSeqInner<'T>>) = agent.Receive()
       let! next = input
       let res = 

src/FSharp.Control.AsyncSeq/AsyncSeq.fs

@@ -13,13 +13,13 @@ open System.Threading
 /// Wrapper for the standard F# agent (MailboxProcessor) that
 /// supports stopping of the agent's body using the IDisposable 
 /// interface (the type automatically creates a cancellation token)
-type internal AutoCancelAgent<'T> private (mbox:Agent<'T>, cts:CancellationTokenSource) = 
+type internal AutoCancelAgent<'T> private (mbox:MailboxProcessor<'T>, cts:CancellationTokenSource) = 
 
   /// Start a new disposable agent using the specified body function
   /// (the method creates a new cancellation token for the agent)
   static member Start(f) = 
     let cts = new CancellationTokenSource()
-    new AutoCancelAgent<'T>(Agent<'T>.Start(f, cancellationToken = cts.Token), cts)
+    new AutoCancelAgent<'T>(MailboxProcessor<'T>.Start(f, cancellationToken = cts.Token), cts)
 
   /// Returns the number of unprocessed messages in the message queue of the agent.
   member x.CurrentQueueLength = mbox.CurrentQueueLength

src/FSharp.Control.AsyncSeq/AutoCancelAgent.fs

@@ -23,7 +23,7 @@ type internal BlockingQueueAgent<'T>(maxLength) =
     [<VolatileField>]
     let mutable count = 0
 
-    let agent = Agent.Start(fun agent ->
+    let agent = MailboxProcessor.Start(fun agent ->
 
         let queue = new Queue<'T>()
 

src/FSharp.Control.AsyncSeq/BlockingQueueAgent.fs

@@ -59,7 +59,6 @@
   <Import Project="..\..\.paket\paket.targets" />
   <ItemGroup>
     <Compile Include="Utils.fs" />
-    <Compile Include="Agent.fs" />
     <Compile Include="AutoCancelAgent.fs" />
     <Compile Include="BlockingQueueAgent.fs" />
     <Compile Include="Observable.fs" />