cloudstream

Documentation

Index

• type ContextualServerStream
  • func NewContextualServerStream(ctx context.Context, root grpc.ServerStream) *ContextualServerStream
  • func (s *ContextualServerStream) Context() context.Context

Types

type ContextualServerStream

type ContextualServerStream struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

ContextualServerStream wraps a "normal" grpc.Server stream but replaces the context. This is useful in for example middlewares.

func NewContextualServerStream

func NewContextualServerStream(ctx context.Context, root grpc.ServerStream) *ContextualServerStream

NewContextualServerStream creates a new server stream, that uses the given context.

func (*ContextualServerStream) Context

func (s *ContextualServerStream) Context() context.Context

Context returns the context for this server stream.