MCPcopy
hub / github.com/IBM/sarama / NewMockSequence

Function NewMockSequence

mockresponses.go:48–62  ·  view source on GitHub ↗
(responses ...any)

Source from the content-addressed store, hash-verified

46}
47
48func NewMockSequence(responses ...any) *MockSequence {
49 ms := &MockSequence{}
50 ms.responses = make([]MockResponse, len(responses))
51 for i, res := range responses {
52 switch res := res.(type) {
53 case MockResponse:
54 ms.responses[i] = res
55 case encoderWithHeader:
56 ms.responses[i] = NewMockWrapper(res)
57 default:
58 panic(fmt.Sprintf("Unexpected response type: %T", res))
59 }
60 }
61 return ms
62}
63
64func (mc *MockSequence) For(reqBody versionedDecoder) (res encoderWithHeader) {
65 res = mc.responses[0].For(reqBody)

Calls 1

NewMockWrapperFunction · 0.85