obsbrowser

Documentation

Index

• type Browser
  • func New(ctx context.Context) *Browser
  • func (o *Browser) CloseObject(ctx context.Context, u uuid.UUID)
  • func (o *Browser) Dispatch(ctx context.Context, b string) error
  • func (o *Browser) Send(ctx context.Context, msg string) types.ObsSendObject
  • func (o *Browser) SendChan() chan string
• type SendObject
  • func (s *SendObject) Done() chan struct{}
  • func (s *SendObject) Receive() chan string

Types

type Browser

type Browser struct {
	Chan         chan string
	Receivers    map[uuid.UUID]*SendObject
	LastAccessed map[uuid.UUID]time.Time
	Mu           sync.Mutex
}

func New

func New(ctx context.Context) *Browser

func (*Browser) CloseObject

func (o *Browser) CloseObject(ctx context.Context, u uuid.UUID)

func (*Browser) Dispatch

func (o *Browser) Dispatch(ctx context.Context, b string) error

func (*Browser) Send

func (o *Browser) Send(ctx context.Context, msg string) types.ObsSendObject

TODO optimize cleaner with priority queue

func (*Browser) SendChan

func (o *Browser) SendChan() chan string

type SendObject

type SendObject struct {
	DoneChan    chan struct{}
	ReceiveChan chan string
}

func (*SendObject) Done

func (s *SendObject) Done() chan struct{}

func (*SendObject) Receive

func (s *SendObject) Receive() chan string