internal

Documentation

Index

• type Receiver
  • func NewReceiver[T any](buf uint) *Receiver[T]
  • func (r *Receiver[T]) Close(_ int, _ *bool) (err error)
  • func (r *Receiver[T]) Send(item T, _ *bool) (err error)

Types

type Receiver

type Receiver[T any] struct {
	Channel chan T
}

Receiver needs to be exported to be used as an RPC handler.

func NewReceiver

func NewReceiver[T any](buf uint) *Receiver[T]

func (*Receiver[T]) Close

func (r *Receiver[T]) Close(_ int, _ *bool) (err error)

Close implements the function signature for an RPC handler. It handles a client closing the communication over the rpchan.

func (*Receiver[T]) Send

func (r *Receiver[T]) Send(item T, _ *bool) (err error)

Send implements the function signature for an RPC handler.