Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/peer-calls/peer-calls
/ functions
Functions
1,240 in github.com/peer-calls/peer-calls
⨍
Functions
1,240
◇
Types & classes
551
↓ 1 callers
Method
start
(pingTicker clock.Ticker)
server/udptransport2/factory.go:218
↓ 1 callers
Method
start
()
server/udptransport2/manager.go:68
↓ 1 callers
Method
start
(in <-chan PubTrackEvent)
server/pubsub/events.go:46
↓ 1 callers
Method
startLoop
()
server/udpmux/udpmux.go:104
↓ 1 callers
Method
startRTCPLoop
(ctx context.Context, stream *playStream)
server/cli/play.go:211
↓ 1 callers
Method
startRTPLoop
(ctx context.Context, stream *playStream)
server/cli/play.go:185
↓ 1 callers
Method
startReadLoop
()
server/servertransport/metadata_transport.go:127
↓ 1 callers
Method
startReadLoop
()
server/udptransport2/control_transport.go:46
↓ 1 callers
Method
startReadLoop
()
server/pubsub/track_reader.go:52
↓ 1 callers
Method
startReading
(ctx context.Context)
server/udpmux/udpmux.go:252
↓ 1 callers
Method
startReading
(ctx context.Context)
server/stringmux/stringmux.go:207
↓ 1 callers
Method
startRoomEventLoop
()
server/nodemanager.go:213
↓ 1 callers
Function
startSignalling
( t *testing.T, wsClient *server.Client, wsRecvCh <-chan message.Message, clientID identifiers.ClientID,
server/sfu_test.go:83
↓ 1 callers
Method
startTransportEventLoop
()
server/nodemanager.go:101
↓ 1 callers
Method
startWriteLoop
()
server/servertransport/metadata_transport.go:91
↓ 1 callers
Method
startWriteLoop
()
server/udptransport2/control_transport.go:78
↓ 1 callers
Function
stopTrack
(track: MediaStreamTrack)
src/client/reducers/streams.ts:298
↓ 1 callers
Method
sub
(pub publisher, tr Transport)
server/pubsub/pubsub.go:161
↓ 1 callers
Method
subscribe
Reads from subscribed keys and dispatches relevant messages to client websockets. This method blocks until the context is closed.
server/redisadapter.go:329
↓ 1 callers
Method
subscribe
()
server/servertransport/track_local.go:138
↓ 1 callers
Method
subscribeUntilReady
(timeout time.Duration)
server/redisadapter.go:368
↓ 1 callers
Function
toggle
(state: SidebarState)
src/client/reducers/sidebar.ts:14
↓ 1 callers
Function
unminimize
(state: WindowStates, key: string)
src/client/reducers/windowStates.ts:17
↓ 1 callers
Method
unsafeAddTrack
(streamId: string, track: MediaStreamTrack)
src/client/audio/AudioProcessor.ts:53
↓ 1 callers
Method
updateJitter
Report is implemented according to the RFC 3550 Appendix A.8.
server/sfu/stats/source.go:120
↓ 1 callers
Method
updateSeq
updateSeq is implemented according to the RFC 3550 Appendix A.1.
server/sfu/stats/source.go:63
↓ 1 callers
Function
waitForUsersEvent
(t *testing.T, ctx context.Context, ch <-chan message.Message)
server/sfu_test.go:63
↓ 1 callers
Function
withDefault
( state: Partial<SettingsState> | null, init: SettingsState, )
src/client/reducers/settings.ts:21
↓ 1 callers
Function
workerFunc
( encodeHeader: EncodeHeader, headerSizeBytes: number, )
src/client/codec/index.ts:62
Method
Add
(room identifiers.RoomID, transport transport.Transport)
server/mux_test.go:46
Method
Add
(client server.ClientWriter)
server/mesh_test.go:69
Method
Add
(client ClientWriter)
server/wsadapter.go:17
Method
Add
Add wraps MultiErr.Add with a mutex lock.
server/multierr/sync.go:12
Method
Add
(fn func())
server/test/testcloser.go:25
Method
Add
Add adds a transport with ClientID. If there was already an existing Transport with the same ClientID, it will be closed and removed before a new one
server/sfu/peer_manager.go:80
Method
Add
Add adds a transport to the existing PeerManager. If the manager does not exist, it is created. NOTE: rooms are created when the peer joins the room
server/sfu/tracks_manager.go:40
Method
AddTrack
(t transport.Track)
server/webrtctransport.go:392
Method
AddTrack
(Track)
server/transport/transport.go:30
Method
AddTrack
(track transport.Track)
server/servertransport/metadata_transport.go:315
Method
AddTrack
(track transport.Track)
server/pubsub/pubsub_test.go:475
Function
BenchmarkDefer
(b *testing.B)
server/juju_test.go:57
Function
BenchmarkJuju
(b *testing.B)
server/juju_test.go:38
Function
BenchmarkLogger_Disabled
(b *testing.B)
server/logger/logger_test.go:307
Function
BenchmarkLogger_Enabled
(b *testing.B)
server/logger/logger_test.go:324
Function
BenchmarkLogger_EnabledWithoutSorting
(b *testing.B)
server/logger/logger_test.go:341
Function
BenchmarkNewUUID_base62
(b *testing.B)
server/uuid/uuid_test.go:20
Function
BenchmarkNewUUID_normal
(b *testing.B)
server/uuid/uuid_test.go:14
Function
BenchmarkNoDefer
(b *testing.B)
server/juju_test.go:63
Function
BenchmarkNoJuju
(b *testing.B)
server/juju_test.go:33
Method
Broadcast
(message message.Message)
server/mesh_test.go:77
Method
C
C implements the Ticker and Timer interfaces.
server/clock/mock.go:129
Method
C
C implements the Ticker interface.
server/clock/clock.go:83
Method
C
C implements the timer interface.
server/clock/clock.go:158
Method
ClientID
()
server/webrtctransport.go:338
Method
ClientID
()
server/transport/transport.go:19
Method
ClientID
()
server/servertransport/transport.go:130
Method
ClientID
()
server/pubsub/pubsub_test.go:466
Method
Clients
()
server/mesh_test.go:86
Method
Close
Close closes the subscription, but not the redis clients
server/redisadapter.go:412
Method
Close
()
server/nodemanager.go:268
Method
Close
()
server/mesh_test.go:90
Method
Close
(statusCode websocket.StatusCode, reason string)
server/test_test.go:55
Method
Close
()
server/wsadapter.go:25
Method
Close
()
server/memoryadapter.go:54
Method
Close
()
server/datatransceiver.go:142
Method
Close
()
server/servertransport/media_stream.go:287
Method
Close
()
server/servertransport/rtcp_reader.go:53
Method
Close
()
server/servertransport/track_remote.go:127
Method
Close
()
server/servertransport/track_local.go:146
Method
Close
()
server/servertransport/metadata_transport.go:408
Method
Close
()
server/servertransport/data_transport.go:108
Method
Close
()
server/cli/play/rtcp_reader.go:56
Method
Close
()
server/cli/play/rtp_reader.go:80
Method
Close
()
server/cli/play/rtcp_writer.go:49
Method
Close
()
server/test/testcloser.go:10
Method
Close
()
server/udpmux/udpmux.go:286
Method
Close
()
server/udpmux/conn.go:32
Method
Close
()
server/stringmux/conn.go:42
Method
Close
()
server/stringmux/stringmux.go:285
Method
Close
()
server/sfu/peer_manager.go:460
Method
Close
()
server/udptransport2/factory.go:562
Method
Close
()
server/udptransport2/control_transport.go:126
Method
Close
Close closes the subscription channel. The caller must ensure that no other methods are called after close has been called.
server/pubsub/pubsub.go:343
Method
CloseWrite
()
server/stringmux/conn.go:38
Method
CloseWrite
()
server/udptransport2/transport.go:51
Method
Conns
Conns is the channel with incoming connections. Users should use either AcceptConn or Conns, but never both.
server/stringmux/stringmux.go:246
Method
Ctx
Ctx implements Logger.
server/logger/logger.go:94
Method
Debug
Debug implements Logger.
server/logger/logger.go:189
Method
Deserialize
(data []byte)
server/wsmessage.go:25
Method
Done
()
server/wrtcnegotiator.go:73
Method
Done
()
server/webrtctransport.go:356
Method
Done
()
server/servertransport/transport.go:134
Method
Done
()
server/udpmux/udpmux.go:282
Method
Done
()
server/udpmux/conn.go:15
Method
Done
()
server/udpmux/conn.go:54
Method
Done
()
server/stringmux/conn.go:64
Method
Done
()
server/stringmux/stringmux.go:308
Method
Done
()
server/udptransport2/factory.go:536
Method
Done
()
server/pubsub/events.go:126
Method
Emit
(clientID identifiers.ClientID, msg message.Message)
server/redisadapter.go:487
← previous
next →
701–800 of 1,240, ranked by callers