3 commits

Author	SHA1	Message	Date
kim	291e180990	[bugfix] fix possible mutex lockup during streaming code (#2633) ... * rewrite Stream{} to use much less mutex locking, update related code * use new context for the stream context * ensure stream gets closed on return of writeTo / readFrom WSConn() * ensure stream write timeout gets cancelled * remove embedded context type from Stream{}, reformat log messages for consistency * use c.Request.Context() for context passed into Stream().Open() * only return 1 boolean, fix tests to expect multiple stream types in messages * changes to ping logic * further improved ping logic * don't export unused function types, update message sending to only include relevant stream type * ensure stream gets closed 🤦 * update to error log on failed json marshal (instead of panic) * inverse websocket read error checking to _ignore_ expected close errors	2024-02-20 18:07:49 +00:00
Daenney	5e2bf0bdca	[chore] Improve copyright header handling (#1608) ... * [chore] Remove years from all license headers Years or year ranges aren't required in license headers. Many projects have removed them in recent years and it avoids a bit of yearly toil. In many cases our copyright claim was also a bit dodgy since we added the 2021-2023 header to files created after 2021 but you can't claim copyright into the past that way. * [chore] Add license header check This ensures a license header is always added to any new file. This avoids maintainers/reviewers needing to remember to check for and ask for it in case a contribution doesn't include it. * [chore] Add missing license headers * [chore] Further updates to license header * Use the more common // indentend comment format * Remove the hack we had for the linter now that we use the // format * Add SPDX license identifier	2023-03-12 16:00:57 +01:00
tobi	b6fbdc66c1	[chore] Deinterface processor and subprocessors (#1501) ... * [chore] Deinterface processor and subprocessors * expose subprocessors via function calls * missing license header	2023-02-22 16:05:26 +01:00

Renamed from internal/processing/streaming/notification.go (Browse further)