Struct testStream

core/transfer/streaming/stream_test.go:174–179

}

type testStream struct {
	send   chan<- typeurl.Any
	recv   <-chan typeurl.Any
	closer chan struct{}
	remote <-chan struct{}
}

func (ts *testStream) Send(a typeurl.Any) error {
	select {