Lines Matching refs:GetStream
55 defer resp.GetStream().Close()
58 for event := range resp.GetStream().Events() {
68 if err := resp.GetStream().Err(); err != nil {
93 resp.GetStream().Close()
94 <-resp.GetStream().Events()
96 if err := resp.GetStream().Err(); err != nil {
145 defer resp.GetStream().Close()
148 for event := range resp.GetStream().Events() {
158 if err := resp.GetStream().Err(); err != nil {
196 defer resp.GetStream().Close()
200 if err = resp.GetStream().Err(); err != nil {
203 event := <-resp.GetStream().Events()
205 b.Fatalf("expect event, got nil, %v, %d", resp.GetStream().Err(), i)
247 defer resp.GetStream().Close()
250 for event := range resp.GetStream().Events() {
260 if err := resp.GetStream().Err(); err != nil {
286 resp.GetStream().Err()
288 case _, ok := <-resp.GetStream().Events():
295 resp.GetStream().Close()
296 <-resp.GetStream().Events()
298 if err := resp.GetStream().Err(); err != nil {
347 defer resp.GetStream().Close()
350 for event := range resp.GetStream().Events() {
360 if err := resp.GetStream().Err(); err != nil {
398 defer resp.GetStream().Close()
402 if err = resp.GetStream().Err(); err != nil {
405 event := <-resp.GetStream().Events()
407 b.Fatalf("expect event, got nil, %v, %d", resp.GetStream().Err(), i)
627 defer resp.GetStream().Close()
629 <-resp.GetStream().Events()
631 err = resp.GetStream().Err()