diff options
author | Philipp Haller <hallerp@gmail.com> | 2010-04-11 17:43:54 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2010-04-11 17:43:54 +0000 |
commit | 8ee1f32478b63286b450a1ac5200ce4da39e69ff (patch) | |
tree | bc1c726390c9ce75c2dde0f549bbeea649661409 /src/actors/scala/actors/ActorCanReply.scala | |
parent | 3750235190176d40290186b1578e2513fc6feace (diff) | |
download | scala-8ee1f32478b63286b450a1ac5200ce4da39e69ff.tar.gz scala-8ee1f32478b63286b450a1ac5200ce4da39e69ff.tar.bz2 scala-8ee1f32478b63286b450a1ac5200ce4da39e69ff.zip |
Scaladoc clean-ups for various actor and channe...
Scaladoc clean-ups for various actor and channel types. Actor now
extends InputChannel. Channel now extends CanReply. Review by plocinic.
Diffstat (limited to 'src/actors/scala/actors/ActorCanReply.scala')
-rw-r--r-- | src/actors/scala/actors/ActorCanReply.scala | 29 |
1 files changed, 1 insertions, 28 deletions
diff --git a/src/actors/scala/actors/ActorCanReply.scala b/src/actors/scala/actors/ActorCanReply.scala index 8cba425b4c..fdc3833ec4 100644 --- a/src/actors/scala/actors/ActorCanReply.scala +++ b/src/actors/scala/actors/ActorCanReply.scala @@ -13,7 +13,7 @@ package scala.actors import java.util.concurrent.ExecutionException /** - * The ActorCanReply trait provides message send operations that + * The `ActorCanReply` trait provides message send operations that * may result in a response from the receiver. * * @author Philipp Haller @@ -21,13 +21,6 @@ import java.util.concurrent.ExecutionException private[actors] trait ActorCanReply extends ReactorCanReply { thiz: AbstractActor with ReplyReactor => - /** - * Sends <code>msg</code> to this actor and awaits reply - * (synchronous). - * - * @param msg the message to be sent - * @return the reply - */ override def !?(msg: Any): Any = { val replyCh = new Channel[Any](Actor.self(thiz.scheduler)) thiz.send(msg, replyCh) @@ -36,15 +29,6 @@ private[actors] trait ActorCanReply extends ReactorCanReply { } } - /** - * Sends <code>msg</code> to this actor and awaits reply - * (synchronous) within <code>msec</code> milliseconds. - * - * @param msec the time span before timeout - * @param msg the message to be sent - * @return <code>None</code> in case of timeout, otherwise - * <code>Some(x)</code> where <code>x</code> is the reply - */ override def !?(msec: Long, msg: Any): Option[Any] = { val replyCh = new Channel[Any](Actor.self(thiz.scheduler)) thiz.send(msg, replyCh) @@ -54,13 +38,6 @@ private[actors] trait ActorCanReply extends ReactorCanReply { } } - /** - * Sends <code>msg</code> to this actor and immediately - * returns a future representing the reply value. - * The reply is post-processed using the partial function - * <code>handler</code>. This also allows to recover a more - * precise type for the reply value. - */ override def !![A](msg: Any, handler: PartialFunction[Any, A]): Future[A] = { val ftch = new Channel[A](Actor.self(thiz.scheduler)) thiz.send(msg, new OutputChannel[Any] { @@ -76,10 +53,6 @@ private[actors] trait ActorCanReply extends ReactorCanReply { Futures.fromInputChannel(ftch) } - /** - * Sends <code>msg</code> to this actor and immediately - * returns a future representing the reply value. - */ override def !!(msg: Any): Future[Any] = { val ftch = new Channel[Any](Actor.self(thiz.scheduler)) val linkedChannel = new AbstractActor { |