MCPcopy
hub / github.com/grpc/grpc-go / ServerStreamingClient

Interface ServerStreamingClient

stream_interfaces.go:24–36  ·  stream_interfaces.go::ServerStreamingClient

ServerStreamingClient represents the client side of a server-streaming (one request, many responses) RPC. It is generic over the type of the response message. It is used in generated code.

Source from the content-addressed store, hash-verified

22// request, many responses) RPC. It is generic over the type of the response
23// message. It is used in generated code.
24type ServerStreamingClient[Res any] interface {
25 // Recv receives the next response message from the server. The client may
26 // repeatedly call Recv to read messages from the response stream. If
27 // io.EOF is returned, the stream has terminated with an OK status. Any
28 // other error is compatible with the status package and indicates the
29 // RPC's status code and message.
30 Recv() (*Res, error)
31
32 // ClientStream is embedded to provide Context, Header, and Trailer
33 // functionality. No other methods in the ClientStream should be called
34 // directly.
35 ClientStream
36}
37
38// ServerStreamingServer represents the server side of a server-streaming (one
39// request, many responses) RPC. It is generic over the type of the response

Callers

nothing calls this directly

Implementers 12

testRPCStreamcredentials/alts/internal/handshaker/h
testUnresponsiveRPCStreamcredentials/alts/internal/handshaker/h
searchServiceV3StreamingSearchClienttestdata/grpc_testing_not_regenerated/
searchServiceV3StreamingSearchServertestdata/grpc_testing_not_regenerated/
v1AlphaServerStreamAdapterreflection/adapt.go
v1AlphaClientStreamAdapterreflection/test/serverreflection_test.
balanceLoadClientStreambalancer/grpclb/grpclb.go
streaminternal/xds/testutils/fakeclient/clie
streaminternal/xds/clients/grpctransport/grp
streaminternal/xds/clients/internal/testutil
ServerHandleinternal/xds/clients/internal/testutil
streaminternal/xds/clients/xdsclient/test/ad

Calls

no outgoing calls

Tested by

no test coverage detected