suspendchan

Documentation

Index

• type Chan
  • func New[T any](buflen int) *Chan[T]
  • func (c *Chan[T]) ReceiveC() chan T
  • func (c *Chan[T]) Resume()
  • func (c *Chan[T]) SendC() chan T
  • func (c *Chan[T]) Suspend()

Types

type Chan

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

Chan is a wrapper around a channel. Underlying chan must be accessed with ReceiveC method. If the Chan is suspended, ReceiveC will return nil which makes the receiver to block on the Chan.

func New

func New[T any](buflen int) *Chan[T]

New returns a new Chan.

func (*Chan[T]) ReceiveC

func (c *Chan[T]) ReceiveC() chan T

ReceiveC returns the underlying channel for receiving values. If the channel is suspended, it returns nil.

func (*Chan[T]) Resume

func (c *Chan[T]) Resume()

Resume the channel. Reverts previous suspend operation.

func (*Chan[T]) SendC

func (c *Chan[T]) SendC() chan T

SendC returns the underlying channel for sending values.

func (*Chan[T]) Suspend

func (c *Chan[T]) Suspend()

Suspend the channel.