Versions in this module Expand all Collapse all v0 v0.8.0 Apr 22, 2019 Changes in this version + type AddFanAction struct + type FanConn interface + Close func() error + NextReader func() (int, io.Reader, error) + WriteMessage func(int, []byte) error + type FanOutAction struct + type Room struct + func NewRoom(conn SourceConn) *Room + func (r *Room) AddFan(ctx context.Context, conn FanConn) + func (r *Room) Close() + func (r *Room) ConsumeSource(ctx context.Context) error + type RoomID string + type SailServer struct + func ProvideSailServer(assetServer hudServer.AssetServer) SailServer + func (s SailServer) Router() http.Handler + type SourceConn interface + Close func() error + ReadMessage func() (int, []byte, error)