nip46: ensure relayConnectionWorked channel is published to once.
This commit is contained in:
+2
-4
@@ -315,10 +315,8 @@ func (bunker *BunkerClient) RPC(ctx context.Context, method string, params []str
|
|||||||
go func(url string) {
|
go func(url string) {
|
||||||
relay, err := bunker.pool.EnsureRelay(url)
|
relay, err := bunker.pool.EnsureRelay(url)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
select {
|
relayConnectionWorked <- struct{}{}
|
||||||
case relayConnectionWorked <- struct{}{}:
|
|
||||||
default:
|
|
||||||
}
|
|
||||||
if err := relay.Publish(ctx, evt); err == nil {
|
if err := relay.Publish(ctx, evt); err == nil {
|
||||||
select {
|
select {
|
||||||
case bunkerConnectionWorked <- struct{}{}:
|
case bunkerConnectionWorked <- struct{}{}:
|
||||||
|
|||||||
Reference in New Issue
Block a user