subscriber

Documentation

Index

• func NewMultiplier(constructor Constructor, subscribersCount int) message.Subscriber
• type Constructor

Functions

func NewMultiplier

func NewMultiplier(constructor Constructor, subscribersCount int) message.Subscriber

NewMultiplier returns multiplier subscriber decorator, which under the hood is calling subscribe multiple times to increase throughput.

Types

type Constructor

type Constructor func() (message.Subscriber, error)

Constructor is a function that creates a subscriber.