play.libs

Class Comet

Object

play.libs.Comet

public abstract class Comet
extends Object

Provides an easy way to use a Comet formatted output with Akka Streams.

There are two methods that can be used to convert strings and JSON, Comet.string and Comet.json. These methods build on top of the base method, Comet.flow, which takes a Flow of akka.util.ByteString and organizes it into Comet format.

   public Result liveClock() {
        final DateTimeFormatter df = DateTimeFormatter.ofPattern("HH mm ss");
        final Source tickSource = Source.tick(Duration.Zero(), Duration.create(100, MILLISECONDS), "TICK");
        final Source eventSource = tickSource.map((tick) -> df.format(ZonedDateTime.now()));

        final Source<ByteString, NotUsed> flow = eventSource.via(Comet.string("parent.clockChanged"));
        return ok().chunked(flow).as(Http.MimeTypes.HTML);
   }
 

Constructor Summary

Constructors

Constructor and Description
Comet()

Method Summary

Modifier and Type	Method and Description
static akka.stream.javadsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed>	flow(String callbackName) Produces a flow of ByteString with a prepended block and a script wrapper.
static akka.stream.javadsl.Flow<com.fasterxml.jackson.databind.JsonNode,akka.util.ByteString,akka.NotUsed>	json(String callbackName) Produces a flow of ByteString using `Json.stringify` from a Flow of JsonNode.
static akka.stream.javadsl.Flow<String,akka.util.ByteString,akka.NotUsed>	string(String callbackName) Produces a Flow of escaped ByteString from a series of String elements.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Comet

public Comet()

Method Detail

string

public static akka.stream.javadsl.Flow<String,akka.util.ByteString,akka.NotUsed> string(String callbackName)

Produces a Flow of escaped ByteString from a series of String elements. Calls out to Comet.flow internally.

Parameters:

callbackName - the javascript callback method.

Returns:

a flow of ByteString elements.

json

public static akka.stream.javadsl.Flow<com.fasterxml.jackson.databind.JsonNode,akka.util.ByteString,akka.NotUsed> json(String callbackName)

Produces a flow of ByteString using `Json.stringify` from a Flow of JsonNode. Calls out to Comet.flow internally.

Parameters:

callbackName - the javascript callback method.

Returns:

a flow of ByteString elements.

flow

public static akka.stream.javadsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> flow(String callbackName)

Produces a flow of ByteString with a prepended block and a script wrapper.

Parameters:

callbackName - the javascript callback method.

Returns:

a flow of ByteString elements.