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

#2934 - explaining send a bit better in the docs

Browse source
This commit is contained in:
Viktor Klang 2013-01-27 21:47:05 +01:00
parent 68f3dd549d
commit 791bbd1565
3 changed files with 10 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -4,14 +4,9 @@
package akka.agent
import akka.actor._
import akka.japi.{ Function ⇒ JFunc, Procedure ⇒ JProc }
import akka.pattern.ask
import scala.concurrent.stm._
import scala.concurrent.{ ExecutionContext, Future, Promise, Await }
import scala.concurrent.duration.{ FiniteDuration, Duration }
import akka.util.{ SerializedSuspendableExecutionContext, Timeout }
import util.Try
import scala.concurrent.{ ExecutionContext, Future, Promise }
import akka.util.{ SerializedSuspendableExecutionContext }
/**
* Factory method for creating an Agent.

6
akka-docs/rst/java/code/docs/agent/AgentDocTest.java
View file

@ -55,10 +55,12 @@ public class AgentDocTest {
Agent<Integer> agent = new Agent<Integer>(5, ec);
//#send
// send a value
// send a value, enqueues this change
// of the value of the Agent
agent.send(7);
// send a function
// send a Mapper, enqueues this change
// to the value of the Agent
agent.send(new Mapper<Integer, Integer>() {
public Integer apply(Integer i) {
return i * 2;

6
akka-docs/rst/scala/code/docs/agent/AgentDocSpec.scala
View file

@ -48,10 +48,12 @@ class AgentDocSpec extends AkkaSpec {
"send and sendOff" in {
val agent = Agent(0)(ExecutionContext.global)
//#send
// send a value
// send a value, enqueues this change
// of the value of the Agent
agent send 7
// send a function
// send a function, enqueues this change
// to the value of the Agent
agent send (_ + 1)
agent send (_ * 2)
//#send