pipe

Documentation

Index

• func Consume(quit qu.C, handler func([]byte) error, args ...string) *worker.Worker
• func Serve(quit qu.C, handler func([]byte) error) *stdconn.StdConn

Functions

func Consume

func Consume(quit qu.C, handler func([]byte) error, args ...string) *worker.Worker

Consume listens for messages from a child process over a stdio pipe.

func Serve

func Serve(quit qu.C, handler func([]byte) error) *stdconn.StdConn

Serve runs a goroutine processing the FEC encoded packets, gathering them and decoding them to be delivered to a handler function