rpchan

Jan 28, 2024

Changes in this version

type RPChan

+ func (ch *RPChan[T]) Listen() func(func(T) bool)

Sep 5, 2023

Changes in this version

type RPChan

+ func (ch *RPChan[T]) Close() error

Sep 3, 2023

Changes in this version

+ type RPChan struct

+ func (ch *RPChan[T]) Iter() <-chan *T

+ func (ch *RPChan[T]) Receive() (*T, bool)

+ func (ch *RPChan[T]) Send(v any) error

Aug 31, 2023

Changes in this version

+ func New(addr string, buf ...uint) (*rpchan[T], error)

Aug 31, 2023

Changes in this version

+ func Receive(ctx context.Context, buf uint) <-chan *T

+ func Send(t any) error