Method Send

internal/bridge/transfer_e2e_test.go:36–41

(resp *clientpb.SpiteResponse)

}

func (m *mockSpiteStream) Send(resp *clientpb.SpiteResponse) error {
	m.mu.Lock()
	defer m.mu.Unlock()
	m.sent = append(m.sent, resp)
	return nil
}

func (m *mockSpiteStream) Recv() (*clientpb.SpiteRequest, error) {
	req, ok := <-m.recvCh