package atmosphere
- Alphabetic
- By Inheritance
- atmosphere
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- type AtmoReceive = PartialFunction[InboundMessage, Unit]
-
trait
AtmosphereClient
extends AtmosphereClientFilters
Provides a handle for a single Atmosphere connection.
Provides a handle for a single Atmosphere connection.
Each browser or other device which connects to an
atmosphere
route is assigned its own AtmosphereClient, with a uuid. This is a good bet for subclassing if you need to implement your own message distribution logic. Subclasses may define their own ClientFilter logic in addition to the stock ClientFilters already defined, in order to segment message delivery. -
trait
AtmosphereClientFilters
extends Serializable
Useful filters to limit who receives broadcasts.
- trait AtmosphereSupport extends Initializable with Handler with CometProcessor with HttpEventServlet with CometProcessor with ScalatraAsyncSupport
-
case class
BinaryMessage
(content: Array[Byte]) extends ProtocolMessage[Array[Byte]] with Product with Serializable
A message representing an array of bytes sent to/received from a remote party.
A message representing an array of bytes sent to/received from a remote party.
- content
An Array of Bytes representing the content of the message
- abstract class ClientFilter extends Function[AtmosphereResource, Boolean]
- final class DefaultScalatraBroadcaster extends DefaultBroadcaster with ScalatraBroadcaster
-
case class
Disconnected
(who: Disconnector, cause: Option[Throwable]) extends InboundMessage with Product with Serializable
A callback event signaling that the connection has ended, if the cause was an exception thrown then the cause object will be filled in.
A callback event signaling that the connection has ended, if the cause was an exception thrown then the cause object will be filled in.
- cause
A scala.Option of java.lang.Throwable
- sealed trait Disconnector extends AnyRef
-
case class
Error
(cause: Option[Throwable]) extends InboundMessage with Product with Serializable
A callback event signaling that an error has occurred.
A callback event signaling that an error has occurred. if the error was an exception thrown then the cause object will be filled in.
- cause
A scala.Option of java.lang.Throwable
- class Everyone extends ClientFilter
-
sealed
trait
InboundMessage
extends AnyRef
A marker trait for inbound messages
- class JacksonSimpleWireformat extends SimpleJsonWireFormat with JsonMethods
-
case class
JsonMessage
(content: JValue) extends ProtocolMessage[JValue] with Product with Serializable
A message representing a json object sent to/received from a remote party.
A message representing a json object sent to/received from a remote party.
- content
A org.json4s.JValue object
- class Message extends AnyRef
- class NativeSimpleWireFormat extends SimpleJsonWireFormat with JsonMethods
- class OnlySelf extends ClientFilter
-
sealed
trait
OutboundMessage
extends AnyRef
A marker trait for outbound messages
-
trait
ProtocolMessage
[T] extends InboundMessage with OutboundMessage
A base trait for creating messages of different content types
A base trait for creating messages of different content types
- T
The type of content this protocol message represents
- final class RedisScalatraBroadcaster extends RedisBroadcaster with ScalatraBroadcaster
- class ScalatraAtmosphereException extends ScalatraException
- class ScalatraAtmosphereFramework extends AtmosphereFramework
- class ScalatraAtmosphereHandler extends AbstractReflectorAtmosphereHandler
- trait ScalatraBroadcaster extends Broadcaster
-
abstract
class
SimpleJsonWireFormat
extends WireFormat
A protocol format that is just plain and simple json.
A protocol format that is just plain and simple json. This protocol doesn't support acking. It looks at the first character in the message and if it thinks it's JSON it will try to parse it as JSON otherwise it creates a text message
- class SkipSelf extends ClientFilter
-
case class
TextMessage
(content: String) extends ProtocolMessage[String] with Product with Serializable
A message representing a text object sent to/received from a remote party.
A message representing a text object sent to/received from a remote party.
- content
A scala.Predef.String representing the content of the message
-
trait
WireFormat
extends AnyRef
The interface trait for a wire format.
The interface trait for a wire format. Creating a new wire format means implementing these 3 methods.
Value Members
- val ActorSystemKey: String
- val AtmosphereClientKey: String
- val AtmosphereRouteKey: String
- val TrackMessageSize: String
- implicit def atmoResourceWithClient(res: AtmosphereResource): AnyRef { ... /* 2 definitions in type refinement */ }
- object AtmosphereClient extends Serializable
- object ClientDisconnected extends Disconnector with Product with Serializable
-
object
Connected
extends InboundMessage with Product with Serializable
A callback event signaling that the connection has been fully established.
A callback event signaling that the connection has been fully established. This means that any handshakes have been completed successfully too.
When you receive this callback message you can be sure there is someone on the other end.
-
object
Heartbeat
extends InboundMessage with Product with Serializable
A callback event signaling a heartbeat
A callback event signaling a heartbeat
When you receive this heartbeat message you can be sure there is someone on the other end.
- object ScalatraAtmosphereHandler
- object ServerDisconnected extends Disconnector with Product with Serializable