type google.golang.org/grpc/internal/transport.ClientStream

32 uses

	google.golang.org/grpc/internal/transport (current package)
		client_stream.go#L39: type ClientStream struct {
		client_stream.go#L68: func (s *ClientStream) startNonGRPCDataCollection(st *status.Status) {
		client_stream.go#L75: func (s *ClientStream) finalizeNonGRPCStatus() *status.Status {
		client_stream.go#L82: func (s *ClientStream) handleNonGRPCData(f *parsedDataFrame) *status.Status {
		client_stream.go#L92: func (s *ClientStream) Read(n int) (mem.BufferSlice, error) {
		client_stream.go#L101: func (s *ClientStream) Close(err error) {
		client_stream.go#L114: func (s *ClientStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
		client_stream.go#L119: func (s *ClientStream) BytesReceived() bool {
		client_stream.go#L125: func (s *ClientStream) Unprocessed() bool {
		client_stream.go#L129: func (s *ClientStream) waitOnHeader() {
		client_stream.go#L144: func (s *ClientStream) RecvCompress() string {
		client_stream.go#L151: func (s *ClientStream) Done() <-chan struct{} {
		client_stream.go#L159: func (s *ClientStream) Header() (metadata.MD, error) {
		client_stream.go#L172: func (s *ClientStream) TrailersOnly() bool {
		client_stream.go#L180: func (s *ClientStream) Status() *status.Status {
		client_stream.go#L184: func (s *ClientStream) requestRead(n int) {
		client_stream.go#L188: func (s *ClientStream) updateWindow(n int) {
		http2_client.go#L129: 	activeStreams map[uint32]*ClientStream
		http2_client.go#L351: 		activeStreams:         make(map[uint32]*ClientStream),
		http2_client.go#L490: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr, handler stats.Handler) *ClientStream {
		http2_client.go#L492: 	s := &ClientStream{
		http2_client.go#L757: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr, handler stats.Handler) (*ClientStream, error) {
		http2_client.go#L946: func (t *http2Client) closeStream(s *ClientStream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
		http2_client.go#L1111: func (t *http2Client) write(s *ClientStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
		http2_client.go#L1141: func (t *http2Client) getStream(f http2.Frame) *ClientStream {
		http2_client.go#L1151: func (t *http2Client) adjustWindow(s *ClientStream, n uint32) {
		http2_client.go#L1160: func (t *http2Client) updateWindow(s *ClientStream, n uint32) {
		http2_client.go#L1421: 	streamsToClose := make([]*ClientStream, 0)
		transport.go#L133: 	clientStream *ClientStream // The client transport stream is closed with a status representing ctx.Err() and nil trailer metadata.
		transport.go#L626: 	NewStream(ctx context.Context, callHdr *CallHdr, handler stats.Handler) (*ClientStream, error)

	google.golang.org/grpc
		stream.go#L640: 	transportStream *transport.ClientStream
		stream.go#L1391: 	transportStream  *transport.ClientStream