chanx

README

功能介绍

1. 无限长度的chan

Documentation

Index

• type Client
  • func NewClient[T any](preCtx context.Context) *Client[T]
  • func (obj *Client[T]) Add(val T) error
  • func (obj *Client[T]) Chan() <-chan T
  • func (obj *Client[T]) Close()
  • func (obj *Client[T]) Done() <-chan struct{}
  • func (obj *Client[T]) Join()
  • func (obj *Client[T]) Len() int64

Types

type Client

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

func NewClient

func NewClient[T any](preCtx context.Context) *Client[T]

func (*Client[T]) Add

func (obj *Client[T]) Add(val T) error

func (*Client[T]) Chan

func (obj *Client[T]) Chan() <-chan T

func (*Client[T]) Close

func (obj *Client[T]) Close()

func (*Client[T]) Done

func (obj *Client[T]) Done() <-chan struct{}

func (*Client[T]) Join

func (obj *Client[T]) Join()

func (*Client[T]) Len

func (obj *Client[T]) Len() int64