type google.golang.org/grpc/internal/transport.WriteOptions
14 uses
google.golang.org/grpc/internal/transport (current package)
client_stream.go#L114: func (s *ClientStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
handler_server.go#L336: func (ht *serverHandlerTransport) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
http2_client.go#L1111: func (t *http2Client) write(s *ClientStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
http2_server.go#L1150: func (t *http2Server) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
server_stream.go#L70: func (s *ServerStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
transport.go#L560: type WriteOptions struct {
transport.go#L673: write(s *ServerStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error
google.golang.org/grpc
server.go#L1188: func (s *Server) sendResponse(ctx context.Context, stream *transport.ServerStream, msg any, cp Compressor, opts *transport.WriteOptions, comp encoding.Compressor) error {
server.go#L1483: opts := &transport.WriteOptions{Last: true}
stream.go#L1046: a.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
stream.go#L1132: if err := a.transportStream.Write(hdr, payld, &transport.WriteOptions{Last: !cs.desc.ClientStreams}); err != nil {
stream.go#L1434: as.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
stream.go#L1484: if err := as.transportStream.Write(hdr, payload, &transport.WriteOptions{Last: !as.desc.ClientStreams}); err != nil {
stream.go#L1766: if err := ss.s.Write(hdr, payload, &transport.WriteOptions{Last: false}); err != nil {