Function newMockSpiteStream

internal/bridge/transfer_e2e_test.go:30–34

()

}

func newMockSpiteStream() *mockSpiteStream {
	return &mockSpiteStream{
		recvCh: make(chan *clientpb.SpiteRequest, 16),
	}
}

func (m *mockSpiteStream) Send(resp *clientpb.SpiteResponse) error {
	m.mu.Lock()