type google.golang.org/grpc/internal/transport.WriteOptions
14 uses
google.golang.org/grpc/internal/transport (current package)
client_stream.go#L76: 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#L1090: func (t *http2Client) write(s *ClientStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
http2_server.go#L1149: func (t *http2Server) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
server_stream.go#L69: func (s *ServerStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
transport.go#L514: type WriteOptions struct {
transport.go#L615: write(s *ServerStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error
google.golang.org/grpc
server.go#L1171: func (s *Server) sendResponse(ctx context.Context, stream *transport.ServerStream, msg any, cp Compressor, opts *transport.WriteOptions, comp encoding.Compressor) error {
server.go#L1471: opts := &transport.WriteOptions{Last: true}
stream.go#L1007: a.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
stream.go#L1102: if err := a.transportStream.Write(hdr, payld, &transport.WriteOptions{Last: !cs.desc.ClientStreams}); err != nil {
stream.go#L1395: as.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
stream.go#L1445: if err := as.transportStream.Write(hdr, payload, &transport.WriteOptions{Last: !as.desc.ClientStreams}); err != nil {
stream.go#L1718: if err := ss.s.Write(hdr, payload, &transport.WriteOptions{Last: false}); err != nil {