This code shows how we receive and display new chat messages. The client registers a callback which appends all incoming messages to an HTML element with the id 'chatmessages.' Each new value streamed will also have an associated author, sequence number and timestamp.

gistfile1.txt

...
session.stream(chatTopic).asType(diffusion.datatypes.json())
                         .on('value', function (topic, specification, newValue, oldValue) {
                              appendMessageToChat(newValue.value.get(), '#chatmessages');
                          });
...