Matt Comb

This does not work for me, here is my Configure Services stuff. services.Configure(Configuration.GetSection("AppSettings")); var mqttServerOptions = new MqttServerOptionsBuilder() .WithConnectionValidator(c => { // some stuff that works } ) .WithSubscriptionInterceptor(context =>...

Currently I'm able to achieve ws, wss, mqtt but not mqtts (using tcp) It feels like I'm missing an option to add tls to the tcp ?

unfortunately it is not working

The Rx code looks good and looks like ``` Observable.FromAsync(server.AcceptWebSocketAsync) .Select(ws => new ChatSession(ws) { In = Observable.FromAsync(ws.ReadDynamicAsync) .DoWhile(() => ws.IsConnected) .Where(msg => msg != null), Out = Observer.Create(ws.WriteDynamic) })...

I had converted to the following but did not seem to improve the situation. At what point is the websocket lock removed ? ``` public static async void WriteDynamicAsync(this WebSocket...

Hi Denis, thanks for the quick feedback. I have tried to implement the following ``` public static async void WriteDynamicAsync(this WebSocket ws, dynamic data) { using (var messageWriter = ws.CreateMessageWriter(WebSocketMessageType.Text))...

Exception: {System.ObjectDisposedException: Can not access a closed Stream. at System.IO.Compression.DeflateStream.ThrowStreamClosedException() at System.IO.Compression.DeflateStream.WriteAsyncMemory(ReadOnlyMemory`1 buffer, CancellationToken cancellationToken) at System.IO.Compression.DeflateStream.WriteAsync(Byte[] array, Int32 offset, Int32 count, CancellationToken cancellationToken) at vtortola.WebSockets.Deflate.WebSocketDeflateWriteStream.WriteAsync(Byte[] buffer, Int32 offset, Int32...

:) indeed! Thanks Denis, I am now seeing messages flowing again. Appreciate the support! Two more things. Given this observer pattern is it still needed that I return something other...