@@ -196,11 +196,7 @@ func (tss *testStreamingService) EmptyPayloadStream(_ context.Context, _ *emptyp
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := streamer.Send(&streaming.EchoPayload{Seq: 2}); err != nil {
|
return streamer.Send(&streaming.EchoPayload{Seq: 2})
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestStreamingService(t *testing.T) {
|
func TestStreamingService(t *testing.T) {
|
||||||
|
|||||||
Reference in New Issue
Block a user