channel

Documentation

Index

• func GetChannelIndex[Message any](subscribers []FilterableChannel[Message], subscriber <-chan Message) int
• type FilterableChannel
• type MessageFilter

Functions

func GetChannelIndex

func GetChannelIndex[Message any](subscribers []FilterableChannel[Message], subscriber <-chan Message) int

Types

type FilterableChannel

type FilterableChannel[Message any] struct {
	Channel chan Message
	Filter  MessageFilter[Message]
}

type MessageFilter

type MessageFilter[Message any] interface {
	Filter(message Message) bool
}

MessageFilter is an interface that defines a method to filter messages.