MCPcopy Create free account
hub / github.com/DeAI-Artist/Linkis / NewTestReactor

Function NewTestReactor

p2p/switch_test.go:53–62  ·  view source on GitHub ↗
(channels []*conn.ChannelDescriptor, logMessages bool)

Source from the content-addressed store, hash-verified

51}
52
53func NewTestReactor(channels []*conn.ChannelDescriptor, logMessages bool) *TestReactor {
54 tr := &TestReactor{
55 channels: channels,
56 logMessages: logMessages,
57 msgsReceived: make(map[byte][]PeerMessage),
58 }
59 tr.BaseReactor = *NewBaseReactor("TestReactor", tr)
60 tr.SetLogger(log.TestingLogger())
61 return tr
62}
63
64func (tr *TestReactor) GetChannels() []*conn.ChannelDescriptor {
65 return tr.channels

Callers 3

initSwitchFuncFunction · 0.85
BenchmarkSwitchBroadcastFunction · 0.85

Calls 3

TestingLoggerFunction · 0.92
NewBaseReactorFunction · 0.85
SetLoggerMethod · 0.65

Tested by

no test coverage detected