raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Make SecretAgent final (sorry James, you knew it couldn't last forever!) and standardised doc comment.

Browse source 
Add `Actor.create` factory method to 2.1->2.1 migration docs
This commit is contained in:
Kevin Wright 2013-03-06 08:20:50 +00:00
parent f305ed72a8
commit df55bc44c9
2 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-agent/src/main/scala/akka/agent/Agent.scala
View file

@ -15,14 +15,15 @@ object Agent {
def apply[T](initialValue: T)(implicit context: ExecutionContext): Agent[T] = new SecretAgent(initialValue, context)
/**
* Factory method for Java Iterop.
* Java API
* Factory method for creating an Agent.
*/
def create[T](initialValue: T, context: ExecutionContext): Agent[T] = Agent(initialValue)(context)
/**
* Default agent implementation.
*/
private class SecretAgent[T](initialValue: T, context: ExecutionContext) extends Agent[T] {
private final class SecretAgent[T](initialValue: T, context: ExecutionContext) extends Agent[T] {
private val ref = Ref(initialValue)
private val updater = SerializedSuspendableExecutionContext(10)(context)

4
akka-docs/rst/project/migration-guide-2.1.x-2.2.x.rst
View file

@ -64,12 +64,14 @@ Brand new Agents
================
Akka's ``Agent`` has been rewritten to improve the API and to remove the need to manually ``close`` an Agent.
It's also now an abstract class with the potential for subtyping and has a new factory method
allowing Java to correctly infer the type of the Agent.
The Java API has also been harmonized so both Java and Scala call the same methods.
======================================================= =======================================================
Old Java API New Java API
======================================================= =======================================================
``new Agent<type>(value, actorSystem)`` ``new Agent<type>(value, executionContext)``
``new Agent<type>(value, actorSystem)`` ``Agent.create(value, executionContext)``
``agent.update(newValue)`` ``agent.send(newValue)``
``agent.future(Timeout)`` ``agent.future()``
``agent.await(Timeout)`` ``Await.result(agent.future(), Timeout)``