TypeScript socket.io.Socket类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› TypeScript›TypeScript教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了TypeScript中socket.io.Socket类的典型用法代码示例。如果您正苦于以下问题：TypeScript io.Socket类的具体用法？TypeScript io.Socket怎么用？TypeScript io.Socket使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了io.Socket类的4个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1:

 this._io.on("connection", (socket: Socket) => {
     socket.on("register", (req: IRegisterRequest) => {
         this.emitEvents(this._sessionManager.registerClient(socket, req));
     });
     socket.on("roomList", () => {
         this.emitEvents(this._sessionManager.sendLobby(socket));
     });
     socket.on("joinRoom", (req: IJoinRoomRequest) => {
         this.emitEvents(this._sessionManager.joinRoom(socket, req));
     });
     socket.on("leaveRoom", (req: ILeaveRoomRequest) => {
         this.emitEvents(this._sessionManager.leaveRoom(socket, req));
     });
     socket.on("startGame", (req: IStartGameRequest) => {
         this.emitEvents(this._sessionManager.startGame(socket, req));
     });
     socket.on("placeTile", (req: IPlaceTileRequest) => {
         this.emitEvents(this._sessionManager.placeTile(socket, req));
     });
     socket.on("roomMessage", (req: IRoomMessageRequest) => {
         this.emitEvents(this._sessionManager.roomMessage(socket, req));
     });
     socket.on("roomStats", (req: IRoomStatsRequest) => {
         this.emitEvents(this._sessionManager.sendRoomStats(socket, req));
     });
     socket.on("userStats", (req: IUserStatsRequest) => {
         this.emitEvents(this._sessionManager.sendUserStats(socket, req));
     });
     socket.on("globalStats", (async (req: IGlobalStatsRequest) => {
         this.emitEvents(await this._sessionManager.sendGlobalStats(socket, req));
     }));
 });

开发者ID:Parakoopa，项目名称:WhoSquares，代码行数:32，代码来源:RequestManager.ts

示例2:

        this.socket.on('connection', (client: Socket) => {
            this.bus.addClient(client)

            client.on('api.subscription', (subscription: Subscription) => {
                this.bus.subscribe(client.id, subscription)
            })
            client.on('api.unsubscription', (subscription: Subscription) => {
                this.bus.unsubscribe(client.id, subscription.id)
            })
            client.on('disconnect', () => {
                this.bus.removeClient(client.id)
            })
        })

开发者ID:plouc，项目名称:mozaik，代码行数:13，代码来源:mozaik.ts

示例3: Error

  io.on('connection', (socket: Socket) => {
    const openWatchers = new Map<string, WatcherAndSubscribeHook>();

    const unsubscribeWatcher = ({
      watcher,
      subscribeHook,
    }: WatcherAndSubscribeHook) => {
      watcher.stop();
      if (subscribeHook) {
        subscribeHook.unsubscribed(socket.user);
      }
    };

    socket.on('disconnect', () => {
      openWatchers.forEach(unsubscribeWatcher);
    });

    socket.on(
      'resource',
      (
        { type, resourceName, json }: EventResourceParams,
        callback: Callback,
      ): void => {
        try {
          const value = json && decode(json);

          switch (type) {
            case 'cursor toArray': {
              const resource = resourcesService.getCursorResource(resourceName);
              resourcesService
                .createCursor(resource, socket.user, value)
                .then((cursor) => cursor.toArray())
                .then((results) => callback(null, encode(results)))
                .catch((err) => {
                  logger.error(type, err);
                  callback(err.message);
                });
              break;
            }

            case 'fetch':
            case 'subscribe':
            case 'fetchAndSubscribe':
              try {
                const resource = resourcesService.getServiceResource(
                  resourceName,
                );
                logger.info('resource', { type, resourceName, value });

                const [key, params, eventName] = value;

                if (!key.startsWith('query')) {
                  throw new Error('Invalid query key');
                }

                const query = resource.queries[key](params, socket.user);

                if (type === 'fetch') {
                  query
                    .fetch((result: any) =>
                      callback(null, result && encode(result)),
                    )
                    .catch((err: any) => {
                      logger.error(type, { err });
                      callback(err.message || err);
                    });
                } else {
                  const watcherKey = `${resourceName}__${key}`;
                  if (openWatchers.has(watcherKey)) {
                    logger.warn(
                      'Already have a watcher for this key. Cannot add a new one',
                      { watcherKey, key },
                    );
                    callback(
                      'Already have a watcher for this key. Cannot add a new one',
                    );
                    return;
                  }
                  const watcher = query[type](
                    (err: Error | null, result: any) => {
                      if (err) {
                        logger.error(type, { err });
                      }

                      socket.emit(eventName, err, result && encode(result));
                    },
                  );

                  watcher.then(
                    () => callback(null),
                    (err: Error) => {
                      logger.error(type, { err });
                      callback(err.message);
                    },
                  );

                  const subscribeHook =
                    resource.subscribeHooks && resource.subscribeHooks[key];
                  openWatchers.set(watcherKey, { watcher, subscribeHook });
                  if (subscribeHook) {
//.........这里部分代码省略.........

开发者ID:liwijs，项目名称:liwi，代码行数:101，代码来源:index.ts

示例4: encode

                    (err: Error | null, result: any) => {
                      if (err) {
                        logger.error(type, { err });
                      }

                      socket.emit(eventName, err, result && encode(result));
                    },

开发者ID:liwijs，项目名称:liwi，代码行数:7，代码来源:index.ts

注：本文中的socket.io.Socket类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。