eventstream

Documentation

Index

• Constants
• type EventStream
  • func NewEventStream[M any](initial M) *EventStream[M]
  • func (es *EventStream[M]) Leave(ch chan M)
  • func (es *EventStream[M]) Send(m M)
  • func (es *EventStream[M]) Shutdown()
  • func (es *EventStream[M]) Sub() chan M
  • func (es *EventStream[M]) SubStream(ctx context.Context) Stream[M]
• type Stream
  • func NewStream[T any](ctx context.Context, p *EventStream[T]) Stream[T]

Constants

const (
	SUBSCRIBE cmd = iota
	SEND
	LEAVE
	SHUTDOWN
	INIT
)

const TIMEOUT = time.Millisecond * 100

Types

type EventStream

type EventStream[M any] struct {

	// FallbehindFn holds a function that is called when a subscriber falls behind
	// and isn't keeping up with SENDs
	FallbehindFn func(chan M, M)
	// contains filtered or unexported fields
}

func NewEventStream

func NewEventStream[M any](initial M) *EventStream[M]

func (*EventStream[M]) Leave

func (es *EventStream[M]) Leave(ch chan M)

func (*EventStream[M]) Send

func (es *EventStream[M]) Send(m M)

func (*EventStream[M]) Shutdown

func (es *EventStream[M]) Shutdown()

func (*EventStream[M]) Sub

func (es *EventStream[M]) Sub() chan M

func (*EventStream[M]) SubStream

func (es *EventStream[M]) SubStream(ctx context.Context) Stream[M]

type Stream

type Stream[T any] interface {
	Next() (T, error)
	Close() error
}

func NewStream

func NewStream[T any](ctx context.Context, p *EventStream[T]) Stream[T]