Ivan Kozlovic

Results 167 comments of Ivan Kozlovic

@rwrz To clarify, imagine NATS has a buffer with "ABC" - we call write(socketID, buf, 3), this call will return OK even if you have disabled your internet connection (until...

@rwrz Thanks! I am happy that I made myself clear and that it helped you understand what was happening.

I agree that the context is lightweight and one could create one specifically for a given call to another prefix: ``` js, _ := nc.JetStream() js.AddStream(cfg) jsSpoke := nc.JetStream(APIPrefix("Spoke.")) jsSpoke.AddSream(otherCfg)...

The TLS error was due to a bug fixed in #587.

Few things: - the test program is not really correct. I would replace current use of errSub with: ``` errSub := make(chan *nats.Subscription, 1) uc, err := nats.Connect(fmt.Sprintf("nats://127.0.0.1:%d", TEST_PORT), nats.ErrorHandler(func(_...

You have a problem since you are doing time.Since(time.Now()) and don't see where you use `times`. Usually you should use `time.Since(startTime)`

Sorry, so you do start time - current time, it is a bit strange, but ok.

@deepch Thank you. I will investigate this tomorrow and get back to you. I do see it too and there is probably an explanation. Will keep you posted.

Just to reiterate on what @derekcollison mentioned, the case with `3000000` (3,000,000) is "fast" because the server simply closes the connection since it is above the default 1MB limit, and...