Skip to content

Commit

Permalink
Fix errors on TestBaseModule close test.
Browse files Browse the repository at this point in the history
  • Loading branch information
vvuwei committed Sep 11, 2023
1 parent f49f741 commit 9f46443
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/modules/baseModule_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -91,11 +91,11 @@ func TestBaseModule_AttachToOnExistingChannel(t *testing.T) {
}

func TestBaseModule_CloseSuccessfullyCloseInputChannels(t *testing.T) {
//bmSrc := &BaseModule{Outputs: sync.NewMap[string, *Output]()}
// bmSrc := &BaseModule{Outputs: sync.NewMap[string, *Output]()}
bmDst := &BaseModule{Inputs: sync.NewMap[string, *Input]()}
channelName := "data"

//bmSrc.Outputs.Set(channelName, NewOutput(channelName))
// bmSrc.Outputs.Set(channelName, NewOutput(channelName))
bmDst.Inputs.Set(channelName, NewInput(channelName))

input, err := bmDst.Input(channelName)
Expand Down

0 comments on commit 9f46443

Please sign in to comment.