sender

Documentation

Overview

Package sender implements the download sender.

Index

• func Start(conn *websocket.Conn, src <-chan model.Measurement) <-chan model.Measurement

Functions

func Start

func Start(conn *websocket.Conn, src <-chan model.Measurement) <-chan model.Measurement

Start starts the sender in a background goroutine. The sender will send binary messages and measurement messages coming from |src|. Such messages will also be emitted to the returned channel.

Liveness guarantee: the sender will not be stuck sending for more then the DefaultRuntime of the subtest, provided that the consumer will continue reading from the returned channel.