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

26 uses

	google.golang.org/grpc/internal/transport (current package)
		client_stream.go#L31: type ClientStream struct {
		client_stream.go#L54: func (s *ClientStream) Read(n int) (mem.BufferSlice, error) {
		client_stream.go#L63: func (s *ClientStream) Close(err error) {
		client_stream.go#L76: func (s *ClientStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
		client_stream.go#L81: func (s *ClientStream) BytesReceived() bool {
		client_stream.go#L87: func (s *ClientStream) Unprocessed() bool {
		client_stream.go#L91: func (s *ClientStream) waitOnHeader() {
		client_stream.go#L106: func (s *ClientStream) RecvCompress() string {
		client_stream.go#L113: func (s *ClientStream) Done() <-chan struct{} {
		client_stream.go#L121: func (s *ClientStream) Header() (metadata.MD, error) {
		client_stream.go#L134: func (s *ClientStream) TrailersOnly() bool {
		client_stream.go#L142: func (s *ClientStream) Status() *status.Status {
		http2_client.go#L127: 	activeStreams map[uint32]*ClientStream
		http2_client.go#L341: 		activeStreams:         make(map[uint32]*ClientStream),
		http2_client.go#L481: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr) *ClientStream {
		http2_client.go#L483: 	s := &ClientStream{
		http2_client.go#L738: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (*ClientStream, error) {
		http2_client.go#L927: 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#L1090: func (t *http2Client) write(s *ClientStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
		http2_client.go#L1120: func (t *http2Client) getStream(f http2.Frame) *ClientStream {
		http2_client.go#L1130: func (t *http2Client) adjustWindow(s *ClientStream, n uint32) {
		http2_client.go#L1139: func (t *http2Client) updateWindow(s *ClientStream, n uint32) {
		http2_client.go#L1387: 	streamsToClose := make([]*ClientStream, 0)
		transport.go#L569: 	NewStream(ctx context.Context, callHdr *CallHdr) (*ClientStream, error)

	google.golang.org/grpc
		stream.go#L601: 	transportStream *transport.ClientStream
		stream.go#L1353: 	transportStream  *transport.ClientStream