events

package

v0.2.0 Latest Latest Go to latest Published: Oct 14, 2018 License: MIT Imports: 11 Imported by: 0

Details

View Source

const DefaultPolling = time.Millisecond * time.Duration(200)

This section is empty.

func DispatchEvent(
	ctx context.Context,
	client *cdp.Client,
	objectID runtime.RemoteObjectID,
	eventName string,
) (values.Boolean, error)

type EventBroker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewEventBroker() *EventBroker

func (broker *EventBroker) AddEventListener(event string, listener EventListener)

func (broker *EventBroker) AddEventStream(name string, stream rpcc.Stream, msg MessageFactory) error

func (broker *EventBroker) Close() error

func (broker *EventBroker) RemoveEventListener(event string, listener EventListener)

func (broker *EventBroker) Start() error

func (broker *EventBroker) Stop() error

type EventListener func(message interface{})

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

type Function func() (core.Value, error)

type MessageFactory func() interface{}

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

func NewEvalWaitTask(
	client *cdp.Client,
	predicate string,
	timeout time.Duration,
	polling time.Duration,
) *WaitTask

func NewWaitTask(
	fun Function,
	timeout time.Duration,
	polling time.Duration,
) *WaitTask

func (task *WaitTask) Run() (core.Value, error)