| /dports/net-im/dendrite/dendrite-0.5.1/vendor/nhooyr.io/websocket/examples/chat/ |
| H A D | chat.go | 18 type chatServer struct { struct
24 subscriberMessageBuffer int
29 publishLimiter *rate.Limiter
33 logf func(f string, v ...interface{})
36 serveMux http.ServeMux
38 subscribersMu sync.Mutex
39 subscribers map[*subscriber]struct{}
65 func (cs *chatServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
148 func (cs *chatServer) publish(msg []byte) {
164 func (cs *chatServer) addSubscriber(s *subscriber) {
[all …]
|
| /dports/irc/soju/soju-0.3.0/vendor/nhooyr.io/websocket/examples/chat/ |
| H A D | chat.go | 18 type chatServer struct { struct
24 subscriberMessageBuffer int
29 publishLimiter *rate.Limiter
33 logf func(f string, v ...interface{})
36 serveMux http.ServeMux
38 subscribersMu sync.Mutex
39 subscribers map[*subscriber]struct{}
65 func (cs *chatServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
148 func (cs *chatServer) publish(msg []byte) {
164 func (cs *chatServer) addSubscriber(s *subscriber) {
[all …]
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/github.com/fullstorydev/grpcurl/testing/cmd/bankdemo/ |
| H A D | chat.go | 17 type chatServer struct { struct
18 chatsBySession map[string]*session
19 chatsAwaitingAgent []string
20 lastSession int32
21 mu sync.RWMutex
54 func (s *chatServer) ChatCustomer(stream Support_ChatCustomerServer) error {
168 func (s *chatServer) ChatAgent(stream Support_ChatAgentServer) error {
333 …ver) newSession(ctx context.Context, cust string) (*session, chan *ChatEntry, context.CancelFunc) {
359 …sion(ctx context.Context, cust, sessionID string) (*session, chan *ChatEntry, context.CancelFunc) {
386 func (s *chatServer) closeSession(sess *session) {
[all …]
|
| /dports/net/grpcox/grpcox-1.0.0/vendor/github.com/fullstorydev/grpcurl/testing/cmd/bankdemo/ |
| H A D | chat.go | 17 type chatServer struct { struct
18 chatsBySession map[string]*session
19 chatsAwaitingAgent []string
20 lastSession int32
21 mu sync.RWMutex
54 func (s *chatServer) ChatCustomer(stream Support_ChatCustomerServer) error {
168 func (s *chatServer) ChatAgent(stream Support_ChatAgentServer) error {
333 …ver) newSession(ctx context.Context, cust string) (*session, chan *ChatEntry, context.CancelFunc) {
359 …sion(ctx context.Context, cust, sessionID string) (*session, chan *ChatEntry, context.CancelFunc) {
386 func (s *chatServer) closeSession(sess *session) {
[all …]
|
| /dports/net/grpcurl/grpcurl-1.8.5/internal/testing/cmd/bankdemo/ |
| H A D | chat.go | 17 type chatServer struct { struct
18 chatsBySession map[string]*session
19 chatsAwaitingAgent []string
20 lastSession int32
21 mu sync.RWMutex
54 func (s *chatServer) ChatCustomer(stream Support_ChatCustomerServer) error {
168 func (s *chatServer) ChatAgent(stream Support_ChatAgentServer) error {
333 …ver) newSession(ctx context.Context, cust string) (*session, chan *ChatEntry, context.CancelFunc) {
359 …sion(ctx context.Context, cust, sessionID string) (*session, chan *ChatEntry, context.CancelFunc) {
386 func (s *chatServer) closeSession(sess *session) {
[all …]
|
| /dports/security/keybase/client-v5.7.1/go/chat/flip/ |
| H A D | chat_test.go | 16 type chatServer struct { struct
17 shutdownCh chan struct{}
18 inputCh chan GameMessageWrappedEncoded
19 chatClients []*chatClient
20 clock clockwork.FakeClock
21 clockForArchiver clockwork.FakeClock
23 gameHistories map[GameIDKey]GameHistory
88 func (s *chatServer) run(ctx context.Context) {
107 func (s *chatServer) stop() {
120 func (s *chatServer) newClient() *chatClient {
[all …]
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/sample/nio/chatserver/ |
| H A D | ClientReader.java | 49 private final ChatServer chatServer; field in ClientReader
51 ClientReader(ChatServer chatServer, DataReader callback) { in ClientReader()
|
| H A D | MessageReader.java | 48 private final ChatServer chatServer; field in MessageReader
50 public MessageReader(ChatServer chatServer) { in MessageReader()
|
| H A D | NameReader.java | 52 private final ChatServer chatServer; field in NameReader
56 public NameReader(ChatServer chatServer) { in NameReader()
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/sample/nio/chatserver/ |
| H A D | ClientReader.java | 49 private final ChatServer chatServer; field in ClientReader
51 ClientReader(ChatServer chatServer, DataReader callback) { in ClientReader()
|
| H A D | MessageReader.java | 48 private final ChatServer chatServer; field in MessageReader
50 public MessageReader(ChatServer chatServer) { in MessageReader()
|
| H A D | NameReader.java | 52 private final ChatServer chatServer; field in NameReader
56 public NameReader(ChatServer chatServer) { in NameReader()
|
| /dports/games/scorched3d/scorched/src/client/dialogs/ |
| H A D | NetworkChatDialog.cpp | 182 const char *chatServer = OptionsMasterListServer::instance()->getChatServer(); in sendMessage() local
|
| /dports/games/opendungeons/OpenDungeons-0.7.1/source/network/ |
| H A D | ServerNotification.h | 49 chatServer, enumerator
|
| /dports/net-im/licq-osd/licq-f271d55/icq/src/ |
| H A D | chat.h | 184 Licq::TCPSocket chatServer; variable
|
| /dports/net-im/licq-qt-gui/licq-f271d55/icq/src/ |
| H A D | chat.h | 184 Licq::TCPSocket chatServer; variable
|
| /dports/net-im/licq-icq/licq-f271d55/icq/src/ |
| H A D | chat.h | 184 Licq::TCPSocket chatServer; variable
|
| /dports/net-im/licq/licq-f271d55/icq/src/ |
| H A D | chat.h | 184 Licq::TCPSocket chatServer; variable
|
| /dports/net-im/licq-jabber/licq-f271d55/icq/src/ |
| H A D | chat.h | 184 Licq::TCPSocket chatServer; variable
|