code: func (c *Client) RegisterStream(ctx context.Context, in *s.RegisterStreamRequest, opts ...grpc.CallOption) (
  	*s.RegisterStreamResponse, error) {
  
  	resp, err := c.bundleRPC(ctx, opts, &s.BatchRequest_Entry{
  		Value: &s.BatchRequest_Entry_RegisterStream{RegisterStream: in},
  	})
  	if err != nil {
  		return nil, err
  	}
  
  	return resp.GetRegisterStream(), nil
  }
docs: // RegisterStream implements ServicesClient.