async

Documentation

Index

• func Of[T any](task func() (T, error)) chan ActionResult[T]
• type ActionResult
  • func NewActionResult[T any](result T, err error) ActionResult[T]
  • func NewErrorActionResult[T any](err error) ActionResult[T]
• type Stream
  • func NewBufferedStream[T any](bufferSize uint) Stream[T]
  • func NewStream[T any]() Stream[T]

Functions

func Of

func Of[T any](task func() (T, error)) chan ActionResult[T]

Types

type ActionResult

type ActionResult[T any] struct {
	Result T
	Error  error
}

func NewActionResult

func NewActionResult[T any](result T, err error) ActionResult[T]

func NewErrorActionResult

func NewErrorActionResult[T any](err error) ActionResult[T]

type Stream

type Stream[T any] chan ActionResult[T]

func NewBufferedStream

func NewBufferedStream[T any](bufferSize uint) Stream[T]

func NewStream

func NewStream[T any]() Stream[T]