chanx

Documentation

Index

• func Insert[T any](ch chan<- T, value T) bool
• type Stream
  • func New[T any](count int, consumer func(ctx context.Context, channel chan T) error) *Stream[T]
  • func NewWithBuffer[T any](count, buffer int, consumer func(ctx context.Context, channel chan T) error) *Stream[T]
  • func (v *Stream[T]) Close()
  • func (v *Stream[T]) Push(item T) bool
  • func (v *Stream[T]) StartSteaming(ctx context.Context) error

Functions

func Insert

func Insert[T any](ch chan<- T, value T) bool

Types

type Stream

type Stream[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any](count int, consumer func(ctx context.Context, channel chan T) error) *Stream[T]

func NewWithBuffer

func NewWithBuffer[T any](count, buffer int, consumer func(ctx context.Context, channel chan T) error) *Stream[T]

func (*Stream[T]) Close

func (v *Stream[T]) Close()

func (*Stream[T]) Push

func (v *Stream[T]) Push(item T) bool

func (*Stream[T]) StartSteaming

func (v *Stream[T]) StartSteaming(ctx context.Context) error