centrifuge-go

centrifuge-go copied to clipboard

Just a POC at the moment. May be updated later. Most probably WT transport should be pluggable from the outside.

FZambia

Research possibility to compile for WebAssembly

2

Would be nice if `centrifuge-go` could work in WASM env. At this moment there is no understanding which caveats we can meet on this way (some general understanding that we...

FZambia

Relates #67 This pull requests adds possibility to use `centrifuge-go` in browser using compilation to WebAssembly. The implementation here is an adapted code from https://github.com/nhooyr/websocket which supports WASM env for...

FZambia

Tags for Publish

5

When `OnPublished` is called for a message received on a subscribed channel, the `Publication` struct has a `Tags` member which matches up with `tags` as described on https://centrifugal.dev/docs/transports/client_api ("optional tags,...

shaunco

Client and Subscription types should be an interface to allow for mocking

2

`Client` and `Subscription` (and probably others I missed) being exposed from the centrifuge-go library as a `struct` makes it extremely difficult to mock them in unit tests. It would be...

shaunco

This result in "105: already subscribed" error if we'll do this: ``` subs1, _ := client.NewSubscription(ch) subs1.Subscribe() subs1.Close() subs2, _ := client.NewSubscription(ch) subs2.Subscribe() ``` This happens because Close calls `s.centrifuge.removeSubscription()`...

powerman

Client.Close should wait until all goroutines will exit. We're using Centrifugo v3, so I didn't tested is this issue actual for 0.9.x.

powerman

why sse is not supported (unsupported connection endpoint)

4

i try to sse but get error message **_unsupported connection endpoint_** . Why we need this control. [github.com/centrifugal/centrifuge-go/client.go:114](https://github.com/centrifugal/centrifuge-go/blob/9768205622fee3c257bb98d876433ea0f00fb5f7/client.go#L113) ``` for _, e := range endpoints { if !strings.HasPrefix(e, "ws") {...

icobani