concurrent

Documentation

Index

• func ReadLine(r io.ReadCloser) <-chan Line
• func ReadLines(r io.ReadCloser) ([]string, error)
• type Data
  • func Call(ctx context.Context, concurrent int, f Func) []Data
• type Func
• type Line

Functions

func ReadLine

func ReadLine(r io.ReadCloser) <-chan Line

func ReadLines

func ReadLines(r io.ReadCloser) ([]string, error)

Types

type Data

type Data map[string]interface{}

func Call

func Call(
	ctx context.Context, concurrent int, f Func,
) []Data

type Func

type Func func(ctx context.Context, ch chan Data) error

type Line

type Line struct {
	Value string
	Error error
}