MCPcopy
hub / github.com/wavetermdev/waveterm / GetPackets

Method GetPackets

pkg/jobmanager/streammanager_test.go:28–34  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

26}
27
28func (tw *testWriter) GetPackets() []wshrpc.CommandStreamData {
29 tw.mu.Lock()
30 defer tw.mu.Unlock()
31 result := make([]wshrpc.CommandStreamData, len(tw.packets))
32 copy(result, tw.packets)
33 return result
34}
35
36func (tw *testWriter) Clear() {
37 tw.mu.Lock()

Callers 6

TestFlowControlFunction · 0.95
TestSequenceNumberingFunction · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected