22 Commits

Author SHA1 Message Date
Piotr Piotrowski
d6eaa84a03 [ADDED] Creating iterators for sync subscriptions (#1728)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2024-12-17 15:06:23 +01:00
Piotr Piotrowski
94fa0cb994 Deprecate encoded connections (#1674)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2024-07-23 16:46:25 +02:00
Piotr Piotrowski
b868e2a2d6 Update dates in licence headers (#1445)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2023-10-17 18:44:27 +02:00
Piotr Piotrowski
76b92fb24f [IMPROVED] Replace empty interface with any (#1332) 2023-06-27 12:40:21 +02:00
Piotr Piotrowski
1bb385f044 Revert "[IMPROVED] Replace empty interface with any" (#1330)
This reverts commit af3706ecfd.
2023-06-22 10:52:40 +02:00
Piotr Piotrowski
61b0ce9bd4 [IMPROVED] Replace empty interface with any (#1315)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2023-06-14 20:19:55 +02:00
Piotr Piotrowski
32b9daa3d2 [ADDED] Service api improvements (#1160)
Co-authored-by: Tomasz Pietrek <melgaer@gmail.com>
2022-12-20 12:52:16 +01:00
Derek Collison
090c71e95c Assign jsSub during low level subscription
Signed-off-by: Derek Collison <derek@nats.io>
2020-12-03 16:09:52 -08:00
Derek Collison
df59787a1a Changed approach to always set type in low level subscribe
Signed-off-by: Derek Collison <derek@nats.io>
2019-03-14 13:13:48 -07:00
Ivan Kozlovic
f9649c3633 [FIXED] Dispatching of asynchronous callbacks
This is a follow up on #365. Working on another issue and running
tests, I still had a race on the original ach or a panic on send
to close channel.

Move from a channel to a linked list with dedicated lock.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2018-06-11 18:51:55 -06:00
Derek Collison
2f0e8883ae CNCF, move to Apache 2 2018-03-17 13:36:48 -07:00
Sotiris Salloumis
f8a4099a9c Fix of date on copyright 2017-05-19 20:04:36 +02:00
Ivan Kozlovic
dce2211197 Fix netchan encoder's call to async err callback.
Check closed state and send into async cb channel under conn's lock.
2016-01-28 09:09:38 -07:00
Ivan Kozlovic
e66adf0068 Fix some encoders issues.
- Return error when Handler has no argument (would cause nil pointer
  panic)
- Schedule async error callbacks when possible
- Add more tests and increase test coverage
2016-01-27 18:37:04 -07:00
Derek Collison
66e9c074f2 Pending cleanup, added Subscription types 2016-01-19 18:33:46 -07:00
Derek Collison
43c8fecf5e Remove channels for async subscribers, better slow consumer, etc 2016-01-17 17:05:00 -08:00
Derek Collison
9e99c311db lint fixups 2016-01-16 10:44:11 -08:00
Derek Collison
d90c4a3c63 Allow programmable channel sizes for subscribers, #46, #47 2015-01-31 16:55:44 -08:00
Derek Collison
9e6eafcfe6 Added netchan bad arg test 2014-08-06 15:29:09 -07:00
Derek Collison
f2a11f3aec Fix for netchan #25, bumped version 2014-07-27 07:17:16 -07:00
Derek Collison
d503d95864 Fixed #22 to avoid leaking Go routines with netchan implementation 2014-07-25 11:33:55 -07:00
Derek Collison
b409066c50 Added asynch error on channel send 2013-06-21 18:10:44 -07:00