diff --git a/sds/sds.go b/sds/sds.go index 8d77e82..4d45aad 100644 --- a/sds/sds.go +++ b/sds/sds.go @@ -129,7 +129,6 @@ import "C" import ( "encoding/json" "errors" - "fmt" "strconv" "strings" "sync" @@ -257,8 +256,6 @@ func (rm *ReliabilityManager) RegisterCallbacks(callbacks EventCallbacks) { func (rm *ReliabilityManager) OnEvent(eventStr string) { - fmt.Println("------------------- received event: ", eventStr) // TODO: remove after debugging - jsonEvent := jsonEvent{} err := json.Unmarshal([]byte(eventStr), &jsonEvent) if err != nil { diff --git a/sds/sds_test.go b/sds/sds_test.go index 58caac2..36e37f2 100644 --- a/sds/sds_test.go +++ b/sds/sds_test.go @@ -343,7 +343,7 @@ func TestCallback_OnPeriodicSync(t *testing.T) { func TestCallbacks_Combined(t *testing.T) { channelID := "test-cb-combined" - // Create sender and receiver handles + // Create sender and receiver RMs senderRm, err := NewReliabilityManager(channelID) require.NoError(t, err) defer senderRm.Cleanup() @@ -381,7 +381,7 @@ func TestCallbacks_Combined(t *testing.T) { t.Errorf("Unexpected OnMessageSent call on Receiver for %s", 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 }, }