go-sse

go-sse copied to clipboard

👋 Are you using go-sse?

5

Hi there, If you're using `go-sse` for any kind of project or trying to evaluate whether `go-sse` is the right tool for your project, please let me know here what...

tmaxmax

use circular buffer in FiniteReplayProvider

19

Uses NewFiniteReplayProvider() to instantiate the provider instead of direct literal. This allows catching count misconfiguration at instantiation (typically application startup) instead as a later panic. In my opinion all panics...

hugowetterberg

🚧 Roadmap to v1

1

Here's what's planned for v1, listed by priority: - [x] Improve internal parsing API (#6, 1352b29) - [ ] Improve server-side message creation API - [x] A refactor and simplification...

tmaxmax

I've been contemplating for a while now this change. At the point of writing this, all code in `go-sse` is lumped in a single package: `sse`. Inside this package there...

tmaxmax

Alternative SSE client

11

The current client API offers a great deal of flexibility: - with an `sse.Client` multiple `Connection`s with the same configuration can be made - there can be multiple event listeners...

tmaxmax

Memory leak in FiniteReplayProvider

3

The slice operations in the FiniteReplayProvider leads to an infinitely growing buffer of messages as the capacity of the buffer will increase on the first append after each dequeue. Reproduced...

hugowetterberg

Are there any existing providers out there besides Joe?

1

First, thanks for a great little library @tmaxmax ! Just wondering if anyone has implemented a Provider for Redis or RabbitMQ. Are existing providers somehow hosted elsewehere? (or are they...

leomorpho

what happened if the server has internal error when using go-sse as client

3

here is my test code ` r, _ := http.NewRequestWithContext(c, http.MethodPost, "http://xxxx/v1/generate_stream", strings.NewReader(string(bodyS))) conn := sse.NewConnection(r) ubsubscribe := conn.SubscribeToAll(func(event sse.Event) { eventS, _ := json.Marshal(event) switch event.Type { case "cycles",...

zhangxinyang97

Client connects with HTTP/2 but reconnects using HTTP/1.1

5

Hi, I'm using the go-sse client to connect to a SSE server. This works fine. The initial connection is established with HTTP/2. When stopping and starting the server, the client...

hspaay

Conditional publish based on user permissions

1

I'm enjoying this library and impressed by your responsiveness to people's issues! One problem I'm having is I need to filter events per session based on authorization rules in my...

NathanBaulch