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

SimpleSender now works with the companion object

Browse source
This commit is contained in:
Endre Sándor Varga 2013-02-12 13:08:41 +01:00
parent 63264e847a
commit 32d1a0072b
3 changed files with 5 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-tests/src/test/scala/akka/io/UdpFFIntegrationSpec.scala
View file

@ -22,7 +22,7 @@ class UdpFFIntegrationSpec extends AkkaSpec("akka.loglevel = INFO") with Implici
val simpleSender: ActorRef = { val simpleSender: ActorRef = {
val commander = TestProbe() val commander = TestProbe()
commander.send(IO(UdpFF), SimpleSender(Nil)) commander.send(IO(UdpFF), SimpleSender)
commander.expectMsg(SimpleSendReady) commander.expectMsg(SimpleSendReady)
commander.sender commander.sender
} }

1
akka-actor/src/main/scala/akka/io/UdpFF.scala
View file

@ -35,6 +35,7 @@ object UdpFF extends ExtensionKey[UdpFFExt] {
case object Unbind extends Command case object Unbind extends Command
case class SimpleSender(options: immutable.Traversable[SocketOption] = Nil) extends Command case class SimpleSender(options: immutable.Traversable[SocketOption] = Nil) extends Command
object SimpleSender extends SimpleSender(Nil)
case object StopReading extends Command case object StopReading extends Command
case object ResumeReading extends Command case object ResumeReading extends Command

10
akka-docs/rst/scala/io.rst
View file

@ -235,7 +235,7 @@ may handle all close events in the same way.
Throttling Reads and Writes Throttling Reads and Writes
^^^^^^^^^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^^^
TODO *This section is not yet ready. More coming soon*
Using UDP Using UDP
--------- ---------
@ -264,7 +264,7 @@ manager:
.. code-block:: scala .. code-block:: scala
IO(UdpFF) ! SimpleSender() IO(UdpFF) ! SimpleSender
// or with socket options: // or with socket options:
import akka.io.Udp._ import akka.io.Udp._
IO(UdpFF) ! SimpleSender(List(SO.Broadcast(true))) IO(UdpFF) ! SimpleSender(List(SO.Broadcast(true)))
@ -370,12 +370,8 @@ Again, the send does not contain a remote address, as it is always the endpoint
Throttling Reads and Writes Throttling Reads and Writes
^^^^^^^^^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^^^
TODO *This section is not yet ready. More coming soon*
Integration with Iteratees
--------------------------
TODO
Architecture in-depth Architecture in-depth
--------------------- ---------------------