pull

Documentation

Index

• Variables
• func Pull(opts ...interface{}) interface{}
• type Pulls
• type Read
• type Sink
• type SourceCallback
• type SourceCallbackMap
• type Through

Variables

var ErrPullStreamEnd = errors.New("pull stream end")

Functions

func Pull

func Pull(opts ...interface{}) interface{}

Types

type Pulls

type Pulls []interface{}

type Read

type Read func(end error, cb SourceCallback)

type Sink

type Sink func(read Read)

type SourceCallback

type SourceCallback func(end error, data interface{})

type SourceCallbackMap

type SourceCallbackMap func(cb SourceCallback) SourceCallback

type Through

type Through func(read Read) Read