bytesub

Documentation

Overview

Package bytesub provides the ability for many clients to subscribe to the latest value of a byte array.

Index

• type ByteSub
  • func New() *ByteSub
  • func (s *ByteSub) AnnounceLatest(b []byte)
  • func (s *ByteSub) Subscribe(ctx context.Context, w io.Writer) error

Types

type ByteSub

type ByteSub struct {
	// contains filtered or unexported fields
}

func New

func New() *ByteSub

func (*ByteSub) AnnounceLatest

func (s *ByteSub) AnnounceLatest(b []byte)

AnnounceLatest writes b to all of the subscribers, with caveats listed in Subscribe.

func (*ByteSub) Subscribe

func (s *ByteSub) Subscribe(ctx context.Context, w io.Writer) error

Subscribe writes the latest value in a single call to w.Write. It does not guarantee that all values published to AnnounceLatest will be written. However once things catch up, it will write the latest value. If no values have been announced, waits for a value before writing.