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

Function NewReader

pkg/streamclient/streamreader.go:32–34  ·  view source on GitHub ↗
(id string, readWindow int64, ackSender AckSender)

Source from the content-addressed store, hash-verified

30}
31
32func NewReader(id string, readWindow int64, ackSender AckSender) *Reader {
33 return NewReaderWithSeq(id, readWindow, 0, ackSender)
34}
35
36func NewReaderWithSeq(id string, readWindow int64, startSeq int64, ackSender AckSender) *Reader {
37 r := &Reader{

Callers 10

TestBasicReadWriteFunction · 0.85
TestEOFFunction · 0.85
TestFlowControlFunction · 0.85
TestErrorFunction · 0.85
TestCancelFunction · 0.85
TestMultipleWritesFunction · 0.85
TestOutOfOrderPacketsFunction · 0.85
TestOutOfOrderWithDuplicatesFunction · 0.85
TestOutOfOrderWithGapsFunction · 0.85
TestOutOfOrderWithEOFFunction · 0.85

Calls 1

NewReaderWithSeqFunction · 0.85

Tested by 10

TestBasicReadWriteFunction · 0.68
TestEOFFunction · 0.68
TestFlowControlFunction · 0.68
TestErrorFunction · 0.68
TestCancelFunction · 0.68
TestMultipleWritesFunction · 0.68
TestOutOfOrderPacketsFunction · 0.68
TestOutOfOrderWithDuplicatesFunction · 0.68
TestOutOfOrderWithGapsFunction · 0.68
TestOutOfOrderWithEOFFunction · 0.68