Method onFromClient

packages/ai/ai/src/McpServer.ts:171–195

(options)

    const notifications = yield* RpcClient.makeNoSerialization(ServerNotificationRpcs, {
      spanPrefix: "McpServer/Notifications",
      onFromClient(options): Effect.Effect<void> {
        const message = options.message
        if (message._tag !== "Request") {
          return Effect.void
        }
        if (message.tag.includes("list_changed")) {
          if (!listChangedHandles.has(message.tag)) {
            listChangedHandles.set(
              message.tag,
              setTimeout(() => {
                notificationsMailbox.unsafeOffer(message)
                listChangedHandles.delete(message.tag)
              }, 0)
            )
          }
        } else {
          notificationsMailbox.unsafeOffer(message)
        }
        return notifications.write({
          clientId: 0,
          requestId: message.id,
          _tag: "Exit",
          exit: Exit.void as any
        })
      }
    })

    return McpServer.of({