Vlad

Here is how I create a consumer: ``` jetSub, err = c.jetStream.Subscribe(channel, func(msg *nats.Msg) { go c.HandleMessage(ctx, msg, sub) }, opt...) ``` (I already wrote it above in the description)

BTW here is how I create jetstream and subscription: ```go js, err := nc.JetStream() ............ if config.SyncHandler { jetSub, err = js.Subscribe(channel, func(msg *nats.Msg) { c.HandleMessage(ctx, msg, sub) }, opt...)...

Hey @piotrpio, any news? We have to restart our client once a week to flush out the memory allocated by the natsMsg....fortunately this is still a small service and we...

Handler: ```go import "github.com/gofiber/contrib/websocket" type WSConnection = websocket.Conn func (r *Router) WSHandler(c *WSConnection) { id := strings.Clone(c.RemoteAddr().String()) c.EnableWriteCompression(true) c.SetCompressionLevel(flate.BestSpeed + 1) defer c.Close() r.connections.Set(id, c) // Publisher spawns a separate...

Okay I see it, thanks, but yes I could not generate a code with ref: I created UserMeta message with payload: I expected it will create a structure UserMeta and...

Also I see that it is trying to parse the open API schema: ``` Error: json: cannot unmarshal array into Go struct field Specification.servers of type map[string]*asyncapiv3.Server Usage: asyncapi-codegen [flags]...

By the way, the initial example above worked after I added x-go-type: