membroadcaster

Documentation

Index

• type MemoryBroadcaster
  • func New(ctx context.Context) *MemoryBroadcaster
  • func (b *MemoryBroadcaster) AddPeer(t *testing.T, peer interface{})
  • func (b *MemoryBroadcaster) Broadcast(ctx context.Context, ev *types.Event) error
  • func (b *MemoryBroadcaster) Close() error
  • func (b *MemoryBroadcaster) Next(ctx context.Context) (*types.Event, error)

Types

type MemoryBroadcaster

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

func New

func New(ctx context.Context) *MemoryBroadcaster

func (*MemoryBroadcaster) AddPeer

func (b *MemoryBroadcaster) AddPeer(t *testing.T, peer interface{})

AddPeer adds a memory broadcaster peer that new events will be shared with.

func (*MemoryBroadcaster) Broadcast

func (b *MemoryBroadcaster) Broadcast(ctx context.Context, ev *types.Event) error

func (*MemoryBroadcaster) Close

func (b *MemoryBroadcaster) Close() error

func (*MemoryBroadcaster) Next

func (b *MemoryBroadcaster) Next(ctx context.Context) (*types.Event, error)