utils

Documentation

Index

• func AddOnExitFunc(onExit ExitFunc)
• func SetUpProcessInterrupt()
• func WrapChannel[T any, U any](input <-chan T, mapper MapperFunc[T, U]) <-chan U
• type ExitFunc
• type MapperFunc

Functions

func AddOnExitFunc

func AddOnExitFunc(onExit ExitFunc)

func SetUpProcessInterrupt

func SetUpProcessInterrupt()

Sets up receiver for OS interrupt signal.

To run code when that happens, add functions via the AddOnExitFunc(func()) process

func WrapChannel

func WrapChannel[T any, U any](input <-chan T, mapper MapperFunc[T, U]) <-chan U

WrapChannel wraps an input channel into another channel using a mapper function

Types

type ExitFunc

type ExitFunc func()

type MapperFunc

type MapperFunc[T any, U any] func(T) U