Method Recv

internal/bridge/transfer_e2e_test.go:43–49

()

}

func (m *mockSpiteStream) Recv() (*clientpb.SpiteRequest, error) {
	req, ok := <-m.recvCh
	if !ok {
		return nil, context.Canceled
	}
	return req, nil
}

func (m *mockSpiteStream) Header() (metadata.MD, error) { return nil, nil }
func (m *mockSpiteStream) Trailer() metadata.MD         { return nil }