subs

Documentation

Overview

Package subs is responsible for communication between modules and it facilitates dependency decoupling.

Index

• type Subject
  • func (s *Subject[T]) Publish(message T)
  • func (s *Subject[T]) Subscribe(handler events.Handler[T])

Types

type Subject

type Subject[T any] struct {
	// contains filtered or unexported fields
}

Subject is a single topic, which supports multiple subscribers.

func (*Subject[T]) Publish

func (s *Subject[T]) Publish(message T)

Publish message to all registered subscribers.

func (*Subject[T]) Subscribe

func (s *Subject[T]) Subscribe(handler events.Handler[T])

Subscribe registers a handler for event processing.