cs

Documentation

Index

• func CloseSender[T any](sender sndr.Sender[T]) (err error)
• func CloseServer(server *csrv.Server, wg *sync.WaitGroup) (err error)
• func MakeSender[T any](addr string, clientsCount int, codec cln.Codec[T]) (sender sndr.Sender[T], err error)
• func StartServer[T any](addr string, workersCount int, codec srv.Codec[T], receiver T, ...) (server *csrv.Server, err error)

Functions

func CloseSender

func CloseSender[T any](sender sndr.Sender[T]) (err error)

func CloseServer

func CloseServer(server *csrv.Server, wg *sync.WaitGroup) (err error)

func MakeSender

func MakeSender[T any](addr string, clientsCount int, codec cln.Codec[T]) (
	sender sndr.Sender[T], err error)

func StartServer

func StartServer[T any](addr string, workersCount int, codec srv.Codec[T],
	receiver T, wg *sync.WaitGroup) (server *csrv.Server, err error)