minibus

Documentation

Overview

Package minibus implements a minimalist many-to-many event bus.

Index

• func DropExcess(in <-chan any) <-chan any
• type Bus
  • func (b *Bus) Listen(ctx context.Context) <-chan any
  • func (b *Bus) Send(ctx context.Context, event any) (ok bool)

Functions

func DropExcess

func DropExcess(in <-chan any) <-chan any

DropExcess will wrap a channel to break backpressure between its input and output. It will drop incoming messages when the consumer can't process them fast enough. When the consumer receives, it will always get the most recent message sent by the producer.

Types

type Bus

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

func (*Bus) Listen

func (b *Bus) Listen(ctx context.Context) <-chan any

func (*Bus) Send

func (b *Bus) Send(ctx context.Context, event any) (ok bool)