From 941b3f898eb19845ae632cb7d103913fdec01eed Mon Sep 17 00:00:00 2001
From: SirCipher <tklapwijk92@gmail.com>
Date: Wed, 23 Sep 2020 12:15:33 +0100
Subject: [PATCH] Updates autobahn server example

---
 examples/autobahn-server.rs | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/examples/autobahn-server.rs b/examples/autobahn-server.rs
index 6e88f83..f6e7622 100644
--- a/examples/autobahn-server.rs
+++ b/examples/autobahn-server.rs
@@ -2,7 +2,7 @@ use std::net::{TcpListener, TcpStream};
 use std::thread::spawn;
 
 use log::*;
-use tungstenite::extensions::deflate::DeflateExt;
+use tungstenite::extensions::deflate::{DeflateExt, DeflateConfigBuilder};
 use tungstenite::handshake::HandshakeRole;
 use tungstenite::protocol::WebSocketConfig;
 use tungstenite::server::accept_with_config;
@@ -16,12 +16,16 @@ fn must_not_block<Role: HandshakeRole>(err: HandshakeError<Role>) -> Error {
 }
 
 fn handle_client(stream: TcpStream) -> Result<()> {
+    let deflate_config = DeflateConfigBuilder::default()
+        .max_message_size(None)
+        .build();
+
     let mut socket = accept_with_config(
         stream,
         Some(WebSocketConfig {
             max_send_queue: None,
             max_frame_size: Some(16 << 20),
-            encoder: DeflateExt::default(),
+            encoder: DeflateExt::new(deflate_config),
         }),
     )
     .map_err(must_not_block)?;