ophandler

Documentation

Overview

Package ophandler provides an Op channel reader that redistributes the events into handlers.

Index

• func Loop(src <-chan ws.Op, dst *handler.Handler) <-chan struct{}
• func WaitForDone(ctx context.Context, done <-chan struct{}) error

Functions

func Loop

func Loop(src <-chan ws.Op, dst *handler.Handler) <-chan struct{}

Loop starts a background goroutine that starts reading from src and distributes received events into the given handler. It's stopped once src is closed. The returned channel will be closed once src is closed.

func WaitForDone

func WaitForDone(ctx context.Context, done <-chan struct{}) error

WaitForDone waits for the done channel returned by Loop until the channel is closed or the context expires.