Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Broadcaster ¶
func Broadcaster[T any](in <-chan T) func() <-chan T
Broadcaster returns a function that when called, yields a new channel that receives all values ever sent on the input channel 'in'. New channels receive the full history on subscription, and receivers added after closure see the full buffer and an immediate close. All channel access/updates are internally synchronized.
func UnaryLifetime ¶ added in v0.9.288
func UnaryLifetime[T any](lifetime <-chan T) grpc.UnaryServerInterceptor
UnaryLifetime creates a gRPC interceptor that cancels the context when the lifetime expires. Useful for propagating server shutdown to long-running gRPC calls.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.