respchan

Documentation

Index

• Variables
• type ResponseChannel
  • func New[T rpc.RPCResponse | model.Notification]() *ResponseChannel[T]
  • func (respChan *ResponseChannel[T]) CreateResponseChannel(id string) (chan T, error)
  • func (ws *ResponseChannel[T]) GetResponseChannel(id string) (chan T, bool)
  • func (ws *ResponseChannel[T]) RemoveResponseChannel(id string)

Variables

var ErrIDInUse = errors.New("id already in use")

Types

type ResponseChannel

type ResponseChannel[T rpc.RPCResponse | model.Notification] struct {
	// contains filtered or unexported fields
}

func New

func New[T rpc.RPCResponse | model.Notification]() *ResponseChannel[T]

func (*ResponseChannel[T]) CreateResponseChannel

func (respChan *ResponseChannel[T]) CreateResponseChannel(id string) (chan T, error)

func (*ResponseChannel[T]) GetResponseChannel

func (ws *ResponseChannel[T]) GetResponseChannel(id string) (chan T, bool)

func (*ResponseChannel[T]) RemoveResponseChannel

func (ws *ResponseChannel[T]) RemoveResponseChannel(id string)