package limitparallelrequests

import "github.com/plgd-dev/go-coap/v3/net/client/limitParallelRequests"

Index ¶

• type DoFunc
• type DoObserveFunc
• type LimitParallelRequests
• func New(limit, endpointLimit int64, do DoFunc, doObserve DoObserveFunc) *LimitParallelRequests
• func (c *LimitParallelRequests) Do(req *pool.Message) (*pool.Message, error)
• func (c *LimitParallelRequests) DoObserve(req *pool.Message, observeFunc func(req *pool.Message)) (Observation, error)
• type Observation

Types ¶

type DoFunc ¶

type DoFunc = func(req *pool.Message) (*pool.Message, error)

type DoObserveFunc ¶

type DoObserveFunc = func(req *pool.Message, observeFunc func(req *pool.Message)) (Observation, error)

type LimitParallelRequests ¶

type LimitParallelRequests struct {
	// contains filtered or unexported fields
}

func New ¶

func New(limit, endpointLimit int64, do DoFunc, doObserve DoObserveFunc) *LimitParallelRequests

New creates new LimitParallelRequests. When limit, endpointLimit == 0, then limit is not used.

func (*LimitParallelRequests) Do ¶

func (c *LimitParallelRequests) Do(req *pool.Message) (*pool.Message, error)

func (*LimitParallelRequests) DoObserve ¶

func (c *LimitParallelRequests) DoObserve(req *pool.Message, observeFunc func(req *pool.Message)) (Observation, error)

type Observation ¶

type Observation = interface {
	Cancel(ctx context.Context, opts ...message.Option) error
	Canceled() bool
}

Source Files ¶

limitParallelRequests.go