Add a stream of maps

AddMapStream.java

session
    .feature(Topics.class)
    .addStream(
        "json/data",
        JSON.class,
        new MapStreamAdapter(new MapStream() {
            @Override
            public void onTransformationException(String topicPath, JSON value, Exception e) {
                // Handle errors
            }

            @Override
            public void onValue(
                    String topicPath,
                    TopicSpecification topicSpecification,
                    Map<String, Object> oldValue,
                    Map<String, Object> newValue) {
                // Do something awesome
            }
        }));