Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrListeningData = errors.New("error") ErrPublishingData = errors.New("error") )
Functions ¶
This section is empty.
Types ¶
type GrpcBroadcaster ¶
func NewBroadcaster ¶
func NewBroadcaster[T, S proto.Message](ctx context.Context) *GrpcBroadcaster[T, S]
func (*GrpcBroadcaster[T, S]) Broadcast ¶
func (b *GrpcBroadcaster[T, S]) Broadcast(_ context.Context, value S, utype pb.UpdateType) error
func (*GrpcBroadcaster[T, S]) RcvAndDispatchUpdates ¶
func (b *GrpcBroadcaster[T, S]) RcvAndDispatchUpdates(ctx context.Context, s grpc.ServerStream) error
func (*GrpcBroadcaster[T, S]) Start ¶
func (b *GrpcBroadcaster[T, S]) Start()
func (*GrpcBroadcaster[T, S]) Stop ¶
func (b *GrpcBroadcaster[T, S]) Stop() error
Source Files
Click to show internal directories.
Click to hide internal directories.