|
@@ -156,7 +156,7 @@ bool WebSocket::isOpen() const { return state == State::Open; }
|
|
|
|
|
|
bool WebSocket::isClosed() const { return state == State::Closed; }
|
|
|
|
|
|
-size_t WebSocket::maxMessageSize() const { return DEFAULT_MAX_MESSAGE_SIZE; }
|
|
|
+size_t WebSocket::maxMessageSize() const { return config.maxMessageSize.value_or(DEFAULT_MAX_MESSAGE_SIZE); }
|
|
|
|
|
|
optional<message_variant> WebSocket::receive() {
|
|
|
auto next = mRecvQueue.pop();
|