Cache recovery mode, delta encoding, channel medium layer

README.md

@@ -27,6 +27,8 @@ Library highlights:
 * Possibility to register a custom PUB/SUB Broker and PresenceManager implementations
 * Option to register custom Transport, like [Centrifugo does with WebTransport](https://centrifugal.dev/docs/transports/webtransport)
 * Message recovery mechanism for channels to survive PUB/SUB delivery problems, short network disconnects or node restart
+* Cache channels – a way to quickly deliver latest publication from channel history to the client upon subscription
+* Delta compression for publications inside a channel to reduce bandwidth usage
 * Out-of-the-box Prometheus instrumentation
 * Client SDKs for main application environments all following [single behaviour spec](https://centrifugal.dev/docs/transports/client_api) (see list of SDKs below).
 

_examples/chat_json/index.html

@@ -224,7 +224,7 @@
                 // subscribe on channel and bind various event listeners. Actual
                 // subscription request will be sent after client connects to
                 // a server.
-                const sub = centrifuge.newSubscription(channel);
+                const sub = centrifuge.newSubscription(channel, {});
 
                 sub.on("publication", handlePublication)
                     .on("join", handleJoin)

_examples/chat_json/main.go

@@ -250,11 +250,12 @@ func main() {
 
 	server := &http.Server{
 		Handler:      mux,
-		Addr:         ":" + strconv.Itoa(*port),
+		Addr:         "127.0.0.1:" + strconv.Itoa(*port),
 		ReadTimeout:  10 * time.Second,
 		WriteTimeout: 10 * time.Second,
 	}
 
+	log.Print("Starting server, visit http://localhost:8000")
 	go func() {
 		if err := server.ListenAndServe(); err != nil && !errors.Is(err, http.ErrServerClosed) {
 			log.Fatal(err)