logos-messaging/sds-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/sds-go-bindings.git synced 2026-01-02 14:13:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

removing print and fixing comments

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-21 13:07:23 +03:00
parent 32ea974f2e
commit 780e0423e4
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
sds/sds.go
View File

@ -129,7 +129,6 @@ import "C"
import ( import (
"encoding/json" "encoding/json"
"errors" "errors"
"fmt"
"strconv" "strconv"
"strings" "strings"
"sync" "sync"
@ -257,8 +256,6 @@ func (rm *ReliabilityManager) RegisterCallbacks(callbacks EventCallbacks) {
func (rm *ReliabilityManager) OnEvent(eventStr string) { func (rm *ReliabilityManager) OnEvent(eventStr string) {
fmt.Println("------------------- received event: ", eventStr) // TODO: remove after debugging
jsonEvent := jsonEvent{} jsonEvent := jsonEvent{}
err := json.Unmarshal([]byte(eventStr), &jsonEvent) err := json.Unmarshal([]byte(eventStr), &jsonEvent)
if err != nil { if err != nil {

4
sds/sds_test.go
View File

@ -343,7 +343,7 @@ func TestCallback_OnPeriodicSync(t *testing.T) {
func TestCallbacks_Combined(t *testing.T) { func TestCallbacks_Combined(t *testing.T) {
channelID := "test-cb-combined" channelID := "test-cb-combined"
// Create sender and receiver handles // Create sender and receiver RMs
senderRm, err := NewReliabilityManager(channelID) senderRm, err := NewReliabilityManager(channelID)
require.NoError(t, err) require.NoError(t, err)
defer senderRm.Cleanup() defer senderRm.Cleanup()
@ -381,7 +381,7 @@ func TestCallbacks_Combined(t *testing.T) {
t.Errorf("Unexpected OnMessageSent call on Receiver for %s", messageId) t.Errorf("Unexpected OnMessageSent call on Receiver for %s", messageId)
}, },
OnMissingDependencies: func(messageId MessageID, missingDeps []MessageID) { OnMissingDependencies: func(messageId MessageID, missingDeps []MessageID) {
// This callback is registered on Receiver, used for handleReceiver2 below // This callback is registered on Receiver, used for receiverRm2 below
}, },
} }