Documentation ¶
Index ¶
- func ConcurrentResponseErrors(ctx context.Context, worker func(ctx context.Context, value interface{}) error, ...) chan error
- func ConcurrentResponseItems(ctx context.Context, ...) chan Item
- func ReadErrorsChannel(ch chan error) error
- func ReadItemChannel(ch chan Item) ([]interface{}, error)
- type Item
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConcurrentResponseErrors ¶
func ConcurrentResponseErrors(ctx context.Context, worker func(ctx context.Context, value interface{}) error, parameters ...interface{}) chan error
ConcurrentResponseErrors process with errors channel
func ConcurrentResponseItems ¶
func ConcurrentResponseItems(ctx context.Context, worker func( ctx context.Context, value interface{}, ) (interface{}, error), parameters ...interface{}) chan Item
ConcurrentResponseItems process with items channel
func ReadErrorsChannel ¶
ReadErrorsChannel reads error's channel and constructs error
func ReadItemChannel ¶
ReadItemChannel reads items channel and constructs error
Types ¶
Click to show internal directories.
Click to hide internal directories.