minibus

Documentation

Overview

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

Index

• func DropExcess[T any](in <-chan T) <-chan T
• type Bus
  • func (b *Bus[T]) Listen(ctx context.Context) <-chan T
  • func (b *Bus[T]) Send(ctx context.Context, event T) int

Functions

func DropExcess

func DropExcess[T any](in <-chan T) <-chan T

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[T any] struct {
	// contains filtered or unexported fields
}

func (*Bus[T]) Listen

func (b *Bus[T]) Listen(ctx context.Context) <-chan T

func (*Bus[T]) Send

func (b *Bus[T]) Send(ctx context.Context, event T) int

Send sends a message to all active listeners and returns how many listeners accepted the event.