webrtc

Documentation

Index

• Variables
• func SignalAnswer(conn *webrtc.PeerConnection, cli rpc.Client, lib rpc.Library) error
• func SignalOffer(conn *webrtc.PeerConnection, cli rpc.Client, lib rpc.Library) (func() error, error)
• type Channel
  • func ChannelNew(v *webrtc.DataChannel) *Channel
  • func (x *Channel) Close() error
  • func (x *Channel) CloseHandle(fn func())
  • func (x *Channel) OpenHandle(fn func())
  • func (x *Channel) ReaderChain(dst msg.ReaderTaker) error
  • func (x *Channel) Writer() (msg.Writer, error)
• type Sdp

Variables

var (
	CandidateProcedureName = "webrtcCandidate"
	SdpProcedureName       = "webrtcSdp"
)

Functions

func SignalAnswer

func SignalAnswer(conn *webrtc.PeerConnection, cli rpc.Client, lib rpc.Library) error

SignalAnswer sets up the WebRTC answer side of the signaling process for a peer connection.

The underlying RPC system must be capable of concurrent, as well as recursive calls. Two procedures will be added, whose names are determined by the global variables CandidateProcedureName and SdpProcedureName.

func SignalOffer

func SignalOffer(conn *webrtc.PeerConnection, cli rpc.Client, lib rpc.Library) (func() error, error)

SignalOffer sets up the WebRTC offer side of the signaling process for a peer connection.

The underlying RPC system must be capable of concurrent, as well as recursive calls. Two procedures will be added, whose names are determined by the global variables CandidateProcedureName and SdpProcedureName.

The returned function can be used to start the initial process, as well as renegotiation.

Types

type Channel

type Channel struct {
	V *webrtc.DataChannel
	// contains filtered or unexported fields
}

func ChannelNew

func ChannelNew(v *webrtc.DataChannel) *Channel

ChannelNew wraps a webrtc.DataChannel to fit the msg framework.

func (*Channel) Close

func (x *Channel) Close() error

func (*Channel) CloseHandle

func (x *Channel) CloseHandle(fn func())

func (*Channel) OpenHandle

func (x *Channel) OpenHandle(fn func())

func (*Channel) ReaderChain

func (x *Channel) ReaderChain(dst msg.ReaderTaker) error

func (*Channel) Writer

func (x *Channel) Writer() (msg.Writer, error)

The returned value is also a msg.Canceler. Not concurrent safe.

type Sdp

type Sdp struct {
	Type   webrtc.SDPType
	String string
}

Sdp separates the webrtc.SessionDescription exported part, making it encoding agnostic.