diff --git a/common/changes/@coze/api/feat-taro-multi_2025-02-06-01-53.json b/common/changes/@coze/api/feat-taro-multi_2025-02-06-01-53.json
new file mode 100644
index 00000000..8ec89d1b
--- /dev/null
+++ b/common/changes/@coze/api/feat-taro-multi_2025-02-06-01-53.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/api",
+      "comment": "fix version",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@coze/api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/common/changes/@coze/taro-api/feat-taro-multi_2024-12-23-08-11.json b/common/changes/@coze/taro-api/feat-taro-multi_2024-12-23-08-11.json
new file mode 100644
index 00000000..8ab30b1f
--- /dev/null
+++ b/common/changes/@coze/taro-api/feat-taro-multi_2024-12-23-08-11.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/taro-api",
+      "comment": "remove multiplatform",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@coze/taro-api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/common/changes/@coze/taro-api/feat-taro-multi_2024-12-23-13-09.json b/common/changes/@coze/taro-api/feat-taro-multi_2024-12-23-13-09.json
new file mode 100644
index 00000000..e37ae364
--- /dev/null
+++ b/common/changes/@coze/taro-api/feat-taro-multi_2024-12-23-13-09.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/taro-api",
+      "comment": "example",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@coze/taro-api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/common/changes/@coze/taro-api/feat-taro-multi_2024-12-30-11-19.json b/common/changes/@coze/taro-api/feat-taro-multi_2024-12-30-11-19.json
new file mode 100644
index 00000000..b2be1c5d
--- /dev/null
+++ b/common/changes/@coze/taro-api/feat-taro-multi_2024-12-30-11-19.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/taro-api",
+      "comment": "modify api",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@coze/taro-api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/common/changes/@coze/taro-api/feat-taro-multi_2024-12-31-02-23.json b/common/changes/@coze/taro-api/feat-taro-multi_2024-12-31-02-23.json
new file mode 100644
index 00000000..90a9ddb0
--- /dev/null
+++ b/common/changes/@coze/taro-api/feat-taro-multi_2024-12-31-02-23.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/taro-api",
+      "comment": "weapp",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@coze/taro-api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/common/changes/@coze/taro-api/feat-taro-multi_2025-01-22-10-14.json b/common/changes/@coze/taro-api/feat-taro-multi_2025-01-22-10-14.json
new file mode 100644
index 00000000..f6314af7
--- /dev/null
+++ b/common/changes/@coze/taro-api/feat-taro-multi_2025-01-22-10-14.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/taro-api",
+      "comment": "expose response error",
+      "type": "minor"
+    }
+  ],
+  "packageName": "@coze/taro-api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/common/changes/@coze/taro-api/feat-taro-multi_2025-02-05-03-02.json b/common/changes/@coze/taro-api/feat-taro-multi_2025-02-05-03-02.json
new file mode 100644
index 00000000..2fdedb42
--- /dev/null
+++ b/common/changes/@coze/taro-api/feat-taro-multi_2025-02-05-03-02.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/taro-api",
+      "comment": "fix testcase",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@coze/taro-api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/common/changes/@coze/taro-api/feat-taro-multi_2025-02-05-07-16.json b/common/changes/@coze/taro-api/feat-taro-multi_2025-02-05-07-16.json
new file mode 100644
index 00000000..2db4f32f
--- /dev/null
+++ b/common/changes/@coze/taro-api/feat-taro-multi_2025-02-05-07-16.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/taro-api",
+      "comment": "update version",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@coze/taro-api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/common/changes/@coze/taro-api/feat-taro-multi_2025-02-06-01-53.json b/common/changes/@coze/taro-api/feat-taro-multi_2025-02-06-01-53.json
new file mode 100644
index 00000000..1ee0dd81
--- /dev/null
+++ b/common/changes/@coze/taro-api/feat-taro-multi_2025-02-06-01-53.json
@@ -0,0 +1,11 @@
+{
+  "changes": [
+    {
+      "packageName": "@coze/taro-api",
+      "comment": "fix version",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@coze/taro-api",
+  "email": "yjfengwen@foxmail.com"
+}
diff --git a/examples/coze-js-taro/src/pages/index/index.tsx b/examples/coze-js-taro/src/pages/index/index.tsx
index b9171ad6..fa601721 100644
--- a/examples/coze-js-taro/src/pages/index/index.tsx
+++ b/examples/coze-js-taro/src/pages/index/index.tsx
@@ -1,13 +1,15 @@
 import { useState, useRef } from 'react';
 
 import { useLoad } from '@tarojs/taro';
-import { View, Text, Button } from '@tarojs/components';
+import { View, Text, Button, Switch } from '@tarojs/components';
 import { CozeAPI, AbortController } from '@coze/taro-api';
 import { RoleType, ChatEventType } from '@coze/api';
 import './index.css';
 
 export default function Index() {
-  const [message, setMessage] = useState('');
+  const [streaming, setStreaming] = useState(true);
+  const [streamingMessage, setStreamingMessage] = useState('');
+  const [pollingMessage, setPollingMessage] = useState('');
   const clientRef = useRef<CozeAPI | null>(null);
 
   useLoad(() => {
@@ -18,9 +20,9 @@ export default function Index() {
     });
   });
 
-  const handleClick = async () => {
+  const handleStreamingChat = async () => {
     if (clientRef.current) {
-      setMessage('');
+      setStreamingMessage('');
       try {
         const controller = new AbortController();
         // setTimeout(() => {
@@ -41,7 +43,7 @@ export default function Index() {
         );
         for await (const chunk of res) {
           if (chunk.event === ChatEventType.CONVERSATION_MESSAGE_DELTA) {
-            setMessage(msg => msg + chunk.data.content);
+            setStreamingMessage(msg => msg + chunk.data.content);
           }
           console.log(chunk);
         }
@@ -51,10 +53,62 @@ export default function Index() {
     }
   };
 
+  const handlePollingChat = async () => {
+    if (clientRef.current) {
+      setPollingMessage('');
+      try {
+        const controller = new AbortController();
+        // setTimeout(() => {
+        //   controller.abort();
+        // }, 10);
+
+        const { messages = [] } = await clientRef.current.chat.createAndPoll(
+          {
+            bot_id: process.env.TARO_APP_COZE_BOT_ID ?? '',
+            user_id: 'abc',
+            additional_messages: [
+              { role: RoleType.User, content: 'hello', content_type: 'text' },
+            ],
+          },
+          {
+            signal: controller.signal,
+          },
+        );
+        setPollingMessage(
+          (messages || []).reduce((acc, cur) => {
+            if (cur.type === 'answer') {
+              acc += cur.content;
+            }
+            return acc;
+          }, ''),
+        );
+        console.log('messages: ', messages);
+      } catch (e) {
+        console.log('failed: ', e);
+      }
+    }
+  };
+
   return (
     <View className="index">
-      <Button onClick={handleClick}>streaming chat</Button>
-      <Text>{message}</Text>
+      <View>
+        <Switch
+          checked={streaming}
+          onChange={evt => setStreaming(evt.detail.value)}
+        />
+        <Text>{streaming ? 'streaming' : 'polling'}</Text>
+      </View>
+      {streaming ? (
+        <>
+          <Button onClick={handleStreamingChat}>streaming chat</Button>
+          <Text>{streamingMessage}</Text>
+        </>
+      ) : (
+        <>
+          <Button onClick={handlePollingChat}>polling chat</Button>
+          <Text>{pollingMessage}</Text>
+        </>
+      )}
     </View>
   );
 }
diff --git a/examples/coze-js-taro3/config/index.ts b/examples/coze-js-taro3/config/index.ts
index c260c125..33c3cb64 100644
--- a/examples/coze-js-taro3/config/index.ts
+++ b/examples/coze-js-taro3/config/index.ts
@@ -25,13 +25,7 @@ export default defineConfig(async merge => {
       options: {},
     },
     framework: 'vue3',
-    compiler: {
-      type: 'webpack5',
-      prebundle: {
-        // 1. Don‘t prebundle '@coze/taro-api'
-        exclude: ['@coze/taro-api'],
-      },
-    },
+    compiler: 'webpack5',
     cache: {
       enable: false,
     },
@@ -56,11 +50,6 @@ export default defineConfig(async merge => {
         },
       },
       webpackChain(chain) {
-        // 2. Enable multi-platform support for '@coze/taro-api'
-        chain.resolve.plugin('MultiPlatformPlugin').tap(args => {
-          args[2]['include'] = ['@coze/taro-api'];
-          return args;
-        });
         chain.resolve.plugin('tsconfig-paths').use(TsconfigPathsPlugin);
         chain.module
           .rule('taroApiBabel')
@@ -100,11 +89,6 @@ export default defineConfig(async merge => {
         },
       },
       webpackChain(chain) {
-        // 2. Enable multi-platform support for '@coze/taro-api'
-        chain.resolve.plugin('MultiPlatformPlugin').tap(args => {
-          args[2]['include'] = ['@coze/taro-api'];
-          return args;
-        });
         chain.resolve.plugin('tsconfig-paths').use(TsconfigPathsPlugin);
         chain.module
           .rule('taroApiBabel')
diff --git a/examples/coze-js-taro3/src/pages/index/index.vue b/examples/coze-js-taro3/src/pages/index/index.vue
index 2cdd2eec..2cad9030 100644
--- a/examples/coze-js-taro3/src/pages/index/index.vue
+++ b/examples/coze-js-taro3/src/pages/index/index.vue
@@ -1,12 +1,21 @@
 <template>
   <View class="index">
-    <Button @tap="handleClick">streaming chat</Button>
-    <Text>{{ msg }}</Text>
+    <Switch :checked="streaming" @change="handleChangeMode"></Switch>
+    <Text v-if="streaming">streaming chat</Text>
+    <Text v-else>polling chat</Text>
+    <template v-if="streaming">
+      <Button @tap="handleStreamingChat">streaming chat</Button>
+      <Text>{{ streamingMessage }}</Text>
+    </template>
+    <template v-else>
+      <Button @tap="handlePollingChat">polling chat</Button>
+      <Text>{{ pollingMessage }}</Text>
+    </template>
   </View>
 </template>
 
 <script>
-import { View, Text, Button } from '@tarojs/components';
+import { View, Text, Button, Switch } from '@tarojs/components';
 import { CozeAPI, AbortController } from '@coze/taro-api';
 import { RoleType, ChatEventType } from '@coze/api';
 import { ref } from 'vue';
@@ -17,18 +26,25 @@ export default {
     View,
     Text,
     Button,
+    Switch,
   },
 
   setup() {
-    const msg = ref('');
+    const streaming = ref(true);
+    const streamingMessage = ref('');
+    const pollingMessage = ref('');
     const client = new CozeAPI({
       baseURL: process.env.TARO_APP_COZE_BASE_URL,
       token: process.env.TARO_APP_COZE_PAT ?? '',
       allowPersonalAccessTokenInBrowser: true, // only for test
     });
 
-    async function handleClick() {
-      msg.value = '';
+    function handleChangeMode(evt) {
+      streaming.value = evt.detail.value;
+    }
+
+    async function handleStreamingChat() {
+      streamingMessage.value = '';
       try {
         const controller = new AbortController();
         // setTimeout(() => {
@@ -49,7 +65,7 @@ export default {
         );
         for await (const chunk of res) {
           if (chunk.event === ChatEventType.CONVERSATION_MESSAGE_DELTA) {
-            msg.value += chunk.data.content;
+            streamingMessage.value += chunk.data.content;
           }
           console.log(chunk);
         }
@@ -58,9 +74,45 @@ export default {
       }
     }
 
+    async function handlePollingChat() {
+      pollingMessage.value = '';
+      try {
+        const controller = new AbortController();
+        // setTimeout(() => {
+        //   controller.abort();
+        // }, 10);
+
+        const { messages } = await client.chat.createAndPoll(
+          {
+            bot_id: process.env.TARO_APP_COZE_BOT_ID ?? '',
+            user_id: 'abc',
+            additional_messages: [
+              { role: RoleType.User, content: 'hello', content_type: 'text' },
+            ],
+          },
+          {
+            signal: controller.signal,
+          },
+        );
+        pollingMessage.value = (messages || []).reduce((acc, cur) => {
+          if (cur.type === 'answer') {
+            acc += cur.content;
+          }
+          return acc;
+        }, '');
+        console.log('messages: ', messages);
+      } catch (e) {
+        console.log('failed: ', e);
+      }
+    }
+
     return {
-      msg,
-      handleClick,
+      streaming,
+      streamingMessage,
+      pollingMessage,
+      handleChangeMode,
+      handleStreamingChat,
+      handlePollingChat,
     };
   },
 };
diff --git a/packages/coze-js/package.json b/packages/coze-js/package.json
index 251b6bb6..6a8fb6f5 100644
--- a/packages/coze-js/package.json
+++ b/packages/coze-js/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@coze/api",
-  "version": "1.0.16",
+  "version": "1.0.17",
   "description": "Official Coze Node.js SDK for seamless AI integration into your applications | 扣子官方 Node.js SDK，助您轻松集成 AI 能力到应用中",
   "keywords": [
     "coze",
diff --git a/packages/coze-taro/README.md b/packages/coze-taro/README.md
index e29661fc..8071df90 100644
--- a/packages/coze-taro/README.md
+++ b/packages/coze-taro/README.md
@@ -144,42 +144,6 @@ cp .env.development .env.local # Edit .env.local with your credentials
 npm run dev:weapp
 ```
 
-## Notes
-### Taro@3 + React
-The following configuration is required:
-
-```javascript
-export default defineConfig(() => {
-  compiler: {
-    type: 'webpack5',
-    prebundle: {
-      // 1. Don‘t prebundle '@coze/taro-api'
-      exclude: ['@coze/taro-api'],
-    },
-  },
-
-  mini: {
-    webpackChain(chain) {
-      // 2. Enable multi-platform support for '@coze/taro-api'
-      chain.resolve.plugin('MultiPlatformPlugin').tap(args => {
-        args[2]['include'] = ['@coze/taro-api'];
-        return args;
-      });
-    },
-  },
-
-  h5: {
-    webpackChain(chain) {
-      // 2. Enable multi-platform support for '@coze/taro-api'
-      chain.resolve.plugin('MultiPlatformPlugin').tap(args => {
-        args[2]['include'] = ['@coze/taro-api'];
-        return args;
-      });
-    },
-  }
-});
-```
-
 ## Documentation
 
 For detailed API documentation and guides, visit:
diff --git a/packages/coze-taro/package.json b/packages/coze-taro/package.json
index b95755ae..168defb7 100644
--- a/packages/coze-taro/package.json
+++ b/packages/coze-taro/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@coze/taro-api",
-  "version": "0.0.6",
+  "version": "0.0.7-beta.1",
   "description": "Official Coze Taro SDK for seamless AI integration into your applications | 扣子官方 Taro SDK，助您轻松集成 AI 能力到应用中",
   "keywords": [
     "coze",
@@ -24,7 +24,6 @@
   },
   "license": "MIT",
   "author": "yjfengwen <yjfengwen@gmail.com>",
-  "type": "module",
   "main": "src/index.ts",
   "module": "src/index.ts",
   "types": "src/index.ts",
@@ -62,4 +61,4 @@
     "module": "dist/index.js",
     "types": "dist/index.d.ts"
   }
-}
+}
\ No newline at end of file
diff --git a/packages/coze-taro/src/api.ts b/packages/coze-taro/src/api.ts
new file mode 100644
index 00000000..1d3fd6e8
--- /dev/null
+++ b/packages/coze-taro/src/api.ts
@@ -0,0 +1,106 @@
+/* eslint-disable @typescript-eslint/no-magic-numbers -- ignore */
+/* eslint-disable @typescript-eslint/no-invalid-void-type -- ignore */
+import axios, {
+  type AxiosAdapter,
+  type AxiosInstance,
+  type InternalAxiosRequestConfig,
+  type AxiosResponseHeaders,
+} from 'axios';
+import { request, getEnv, ENV_TYPE } from '@tarojs/taro';
+import {
+  CozeAPI as InnerCozeAPI,
+  type ClientOptions as InnerClientOptions,
+  APIError,
+} from '@coze/api';
+
+import { sharedMixins } from './mixins/shared';
+import { platformMixins } from './mixins/platform';
+
+export interface ClientOptions extends InnerClientOptions {
+  onBeforeAPICall?: (
+    options: unknown,
+  ) => ({ token?: string } | void) | Promise<{ token?: string } | void>;
+}
+
+export class CozeAPI extends InnerCozeAPI {
+  constructor(public options: ClientOptions) {
+    super({ ...options });
+    this.axiosInstance = axios.create({
+      adapter: this.getAdapter(),
+    });
+    (this.axiosInstance as AxiosInstance).interceptors.request.use(
+      async (config: InternalAxiosRequestConfig) => {
+        if (this.options.onBeforeAPICall) {
+          const res = (await this.options.onBeforeAPICall(config)) ?? {};
+          if (res.token) {
+            this.token = res.token;
+            config.headers.Authorization = `Bearer ${res.token}`;
+          }
+        }
+        return config;
+      },
+    );
+
+    this.applyMixins();
+  }
+
+  private getAdapter(): AxiosAdapter | undefined {
+    if (getEnv() === ENV_TYPE.WEB) {
+      return undefined;
+    }
+
+    const taroAdapter: AxiosAdapter = config => {
+      const { url, method, data, headers } = config;
+      const header =
+        typeof headers.toJSON === 'function' ? headers.toJSON() : headers;
+      header['Content-Type'] = header['Content-Type'] || 'application/json';
+      return new Promise((resolve, reject) => {
+        request({
+          url: url as string,
+          // @ts-expect-error -- ignore
+          method: (method ?? 'GET').toUpperCase(),
+          data,
+          header,
+          success: res => {
+            // Request failed
+            if (res.statusCode !== 200 || res.data?.code) {
+              const resData = res.data || {};
+              resData.error = resData.error || resData.detail || {};
+              const resHeader = res.header || {};
+              resHeader['x-tt-logid'] =
+                resHeader['X-Tt-Logid'] ||
+                resHeader['x-tt-logid'] ||
+                resData.error.logid;
+              const error = APIError.generate(
+                res.statusCode,
+                resData,
+                res.errMsg,
+                resHeader as AxiosResponseHeaders,
+              );
+              reject(error);
+            } else {
+              resolve({
+                data: res.data,
+                status: res.statusCode,
+                statusText: res.errMsg,
+                headers: res.header,
+                config,
+              });
+            }
+          },
+          fail: err => {
+            reject(err);
+          },
+        });
+      });
+    };
+    return taroAdapter;
+  }
+
+  private applyMixins() {
+    if (getEnv() !== ENV_TYPE.WEB) {
+      sharedMixins(this);
+      platformMixins(this);
+    }
+  }
+}
diff --git a/packages/coze-taro/src/api/index.h5.ts b/packages/coze-taro/src/api/index.h5.ts
deleted file mode 100644
index 5c342a8f..00000000
--- a/packages/coze-taro/src/api/index.h5.ts
+++ /dev/null
@@ -1,26 +0,0 @@
-import axios, {
-  type AxiosInstance,
-  type InternalAxiosRequestConfig,
-} from 'axios';
-import { CozeAPI as InnerCozeAPI } from '@coze/api';
-
-import { type ClientOptions } from './types';
-
-export class CozeAPI extends InnerCozeAPI {
-  constructor(public options: ClientOptions) {
-    super({ ...options });
-    this.axiosInstance = axios.create();
-    (this.axiosInstance as AxiosInstance).interceptors.request.use(
-      async (config: InternalAxiosRequestConfig) => {
-        if (this.options.onBeforeAPICall) {
-          const res = (await this.options.onBeforeAPICall(config)) ?? {};
-          if (res.token) {
-            this.token = res.token;
-            config.headers.Authorization = `Bearer ${res.token}`;
-          }
-        }
-        return config;
-      },
-    );
-  }
-}
diff --git a/packages/coze-taro/src/api/index.ts b/packages/coze-taro/src/api/index.ts
deleted file mode 100644
index b9800efe..00000000
--- a/packages/coze-taro/src/api/index.ts
+++ /dev/null
@@ -1,39 +0,0 @@
-import Taro from '@tarojs/taro';
-import { CozeAPI as InnerCozeAPI } from '@coze/api';
-
-import { sharedMixins } from '../mixins/shared';
-import { platformMixins } from '../mixins/platform';
-import { type ClientOptions } from './types';
-
-export class CozeAPI extends InnerCozeAPI {
-  constructor(public options: ClientOptions) {
-    super({
-      ...options,
-      axiosOptions: {
-        ...(options.axiosOptions ?? {}),
-        header: {
-          ...options.headers,
-          Authorization: `Bearer ${options.token}`,
-        },
-        responseType: 'text',
-      },
-    });
-    this.axiosInstance = this.wrapRequest.bind(this);
-    sharedMixins(this);
-    platformMixins(this);
-  }
-
-  private async wrapRequest(options: Taro.request.Option) {
-    if (this.options.onBeforeAPICall) {
-      const config = (await this.options.onBeforeAPICall(options)) ?? {};
-      if (config.token) {
-        this.token = config.token;
-        (this.axiosOptions?.header as Record<string, string>).Authorization =
-          `Bearer ${config.token}`;
-        (options.header as Record<string, string>).Authorization =
-          `Bearer ${config.token}`;
-      }
-    }
-    return Taro.request(options);
-  }
-}
diff --git a/packages/coze-taro/src/api/types.ts b/packages/coze-taro/src/api/types.ts
deleted file mode 100644
index 622ba853..00000000
--- a/packages/coze-taro/src/api/types.ts
+++ /dev/null
@@ -1,8 +0,0 @@
-/* eslint-disable @typescript-eslint/no-invalid-void-type -- ignore */
-import { type ClientOptions as InnerClientOptions } from '@coze/api';
-
-export interface ClientOptions extends InnerClientOptions {
-  onBeforeAPICall?: (
-    options: unknown,
-  ) => ({ token?: string } | void) | Promise<{ token?: string } | void>;
-}
diff --git a/packages/coze-taro/src/event-source/base.ts b/packages/coze-taro/src/event-source/base.ts
index 8bb31986..21485310 100644
--- a/packages/coze-taro/src/event-source/base.ts
+++ b/packages/coze-taro/src/event-source/base.ts
@@ -4,6 +4,7 @@ import { EventName, type EventHandler, type EventMessage } from './types';
 
 export abstract class BaseEventSource {
   protected events = new Events();
+  private isClosed = false;
 
   abstract start(): void;
   abstract abort(): void;
@@ -24,11 +25,24 @@ export abstract class BaseEventSource {
     return this;
   }
 
-  trigger(eventName: EventName, args?: unknown) {
+  trigger(
+    eventName: EventName,
+    args: Pick<EventMessage, 'data' | 'errMsg'> = {},
+  ) {
+    // Success/Fail should only fired once
+    if (
+      this.isClosed &&
+      (eventName === EventName.Success || eventName === EventName.Fail)
+    ) {
+      return this;
+    }
+    if (eventName === EventName.Success || eventName === EventName.Fail) {
+      this.isClosed = true;
+    }
     const msg: EventMessage = {
       event: eventName,
-      data: eventName !== EventName.Fail ? args : undefined,
-      errMsg: eventName === EventName.Fail ? (args as string) : undefined,
+      data: args.data,
+      errMsg: args.errMsg,
     };
     this.events.trigger(eventName, msg);
     return this;
diff --git a/packages/coze-taro/src/event-source/index.tt.ts b/packages/coze-taro/src/event-source/index.tt.ts
index b5068aed..89c5f121 100644
--- a/packages/coze-taro/src/event-source/index.tt.ts
+++ b/packages/coze-taro/src/event-source/index.tt.ts
@@ -25,7 +25,7 @@ export class EventSource extends BaseEventSource {
       this.trigger(EventName.Open);
     });
     this.task.onMessage(msg => {
-      this.trigger(EventName.Chunk, msg);
+      this.trigger(EventName.Chunk, { data: msg });
     });
     this.task.onError(e => {
       const errMsg =
@@ -33,7 +33,7 @@ export class EventSource extends BaseEventSource {
       if (this.isAborted) {
         return;
       }
-      this.trigger(EventName.Fail, errMsg);
+      this.trigger(EventName.Fail, { errMsg });
     });
     this.task.onClose(() => {
       this.trigger(EventName.Success);
@@ -45,7 +45,7 @@ export class EventSource extends BaseEventSource {
       this.isAborted = true;
       this.task?.close();
       // fire "fail" manualy
-      this.trigger(EventName.Fail, 'abort');
+      this.trigger(EventName.Fail, { errMsg: 'abort' });
     }
   }
 }
diff --git a/packages/coze-taro/src/event-source/index.weapp.ts b/packages/coze-taro/src/event-source/index.weapp.ts
index e99b6a9a..416196c5 100644
--- a/packages/coze-taro/src/event-source/index.weapp.ts
+++ b/packages/coze-taro/src/event-source/index.weapp.ts
@@ -29,13 +29,13 @@ export class EventSource extends BaseEventSource {
       enableCookie: true,
       timeout,
       fail: err => {
-        this.trigger(EventName.Fail, err.errMsg);
+        this.trigger(EventName.Fail, { errMsg: err.errMsg });
       },
       success: res => {
         if (res.statusCode !== 200) {
-          this.trigger(EventName.Fail, res.errMsg);
+          this.trigger(EventName.Fail, { errMsg: res.errMsg, data: res });
         } else {
-          this.trigger(EventName.Success, res);
+          this.trigger(EventName.Success, { data: res });
         }
       },
     });
@@ -53,7 +53,7 @@ export class EventSource extends BaseEventSource {
 
   private onHeadersReceived() {
     this.task?.onHeadersReceived(res => {
-      this.trigger(EventName.Open, res);
+      this.trigger(EventName.Open, { data: res });
     });
   }
 
@@ -62,6 +62,21 @@ export class EventSource extends BaseEventSource {
       const octets = new Uint8Array(res.data);
       const decoder = new TextDecoder();
       const chunk = decoder.decode(octets);
+
+      // The request may be failed, so we need to check the chunk
+      if (!this.cacheChunk) {
+        const chunkJson = this.safeParseJSON(chunk);
+        if (chunkJson && chunkJson.code) {
+          this.trigger(EventName.Fail, {
+            errMsg: chunkJson.msg,
+            data: chunkJson,
+          });
+          // Abort the request
+          this.abort();
+          return;
+        }
+      }
+
       this.cacheChunk += chunk;
 
       if (this.cacheChunk.endsWith('\n\n')) {
@@ -86,9 +101,17 @@ export class EventSource extends BaseEventSource {
         }
 
         messages.map(msg => {
-          this.trigger(EventName.Chunk, msg);
+          this.trigger(EventName.Chunk, { data: msg });
         });
       }
     });
   }
+
+  private safeParseJSON(str: string) {
+    try {
+      return JSON.parse(str);
+    } catch (e) {
+      return null;
+    }
+  }
 }
diff --git a/packages/coze-taro/src/event-source/request.ts b/packages/coze-taro/src/event-source/request.ts
index de9b31b3..badba147 100644
--- a/packages/coze-taro/src/event-source/request.ts
+++ b/packages/coze-taro/src/event-source/request.ts
@@ -1,7 +1,21 @@
+/* eslint-disable @typescript-eslint/no-magic-numbers -- ignore */
+import { type AxiosResponseHeaders } from 'axios';
+import { getEnv } from '@tarojs/taro';
+import { APIError, type ErrorRes } from '@coze/api';
+
 import { Deferred } from '../helpers/async';
 import { type RequestConfig, EventName } from './types';
+import { EventSource as EventSourceWeapp } from './index.weapp';
+import { EventSource as EventSourceTT } from './index.tt';
 import { EventSource } from './index';
 
+const ES =
+  getEnv() === 'TT'
+    ? EventSourceTT
+    : getEnv() === 'WEAPP'
+      ? EventSourceWeapp
+      : EventSource;
+
 export function sendRequest<Message>(
   config: RequestConfig,
   result: {
@@ -14,7 +28,7 @@ export function sendRequest<Message>(
   result.deferred = new Deferred();
   result.done = false;
 
-  const eventSource = new EventSource(config)
+  const eventSource = new ES(config)
     .on(EventName.Chunk, msg => {
       result.messages.push(msg.data as Message);
       result.deferred?.resolve(msg.data);
@@ -25,7 +39,16 @@ export function sendRequest<Message>(
       result.deferred?.resolve(msg);
     })
     .on(EventName.Fail, msg => {
-      const error = new Error(msg.errMsg);
+      const data = (msg.data as Record<string, unknown>) || {};
+      data.error = data.error || data.detail;
+      const error = APIError.generate(
+        200,
+        data as unknown as ErrorRes,
+        msg.errMsg,
+        {
+          'x-tt-logid': (data as unknown as ErrorRes).error?.logid,
+        } as unknown as AxiosResponseHeaders,
+      );
       result.done = true;
       result.error = error;
       result.deferred?.reject(error);
diff --git a/packages/coze-taro/src/index.ts b/packages/coze-taro/src/index.ts
index 7db9a1a0..9e6ef854 100644
--- a/packages/coze-taro/src/index.ts
+++ b/packages/coze-taro/src/index.ts
@@ -1,4 +1,3 @@
-export { CozeAPI } from './api/index';
-export { type ClientOptions } from './api/types';
+export { CozeAPI, type ClientOptions } from './api';
 
 export { AbortController, AbortSignal } from './helpers/abortcontroller';
diff --git a/packages/coze-taro/src/mixins/mixins.ts b/packages/coze-taro/src/mixins/mixins.ts
index 1dfdf78d..d7e9fbc9 100644
--- a/packages/coze-taro/src/mixins/mixins.ts
+++ b/packages/coze-taro/src/mixins/mixins.ts
@@ -1,4 +1,3 @@
-/* eslint-disable complexity -- ignore */
 /* eslint-disable @typescript-eslint/no-magic-numbers -- ignore */
 import Taro from '@tarojs/taro';
 import {
@@ -7,7 +6,6 @@ import {
   WorkflowEventType,
   WorkflowEvent,
   ChatEventType,
-  CozeError,
   type StreamChatReq,
   type StreamChatData,
   type CreateFileReq,
@@ -68,34 +66,29 @@ export function getWorkflowStreamMixin(api: CozeAPI) {
       result,
     );
 
-    try {
-      while (true) {
-        if (result.done) {
-          break;
-        }
-        if (!result.messages.length) {
-          await result.deferred?.promise;
-          if (result.error) {
-            throw result.error;
-          }
+    while (true) {
+      if (result.done) {
+        break;
+      }
+      if (!result.messages.length) {
+        await result.deferred?.promise;
+        if (result.error) {
+          throw result.error;
         }
-        let message = result.messages.shift();
-        while (message) {
-          if (message.event === WorkflowEventType.DONE) {
-            yield new WorkflowEvent(Number(message.id), WorkflowEventType.DONE);
-          } else {
-            yield new WorkflowEvent(
-              Number(message.id),
-              message.event,
-              JSON.parse(message.data),
-            );
-          }
-          message = result.messages.shift();
+      }
+      let message = result.messages.shift();
+      while (message) {
+        if (message.event === WorkflowEventType.DONE) {
+          yield new WorkflowEvent(Number(message.id), WorkflowEventType.DONE);
+        } else {
+          yield new WorkflowEvent(
+            Number(message.id),
+            message.event,
+            JSON.parse(message.data),
+          );
         }
+        message = result.messages.shift();
       }
-    } catch (e) {
-      const msg = e instanceof Error ? e.message : e;
-      throw new CozeError(`Could not handle message: ${msg}`);
     }
   };
 }
@@ -253,35 +246,30 @@ async function* handleStreamMessages(result: {
   deferred: Deferred | null;
   error: Error | null;
 }): AsyncGenerator<StreamChatData> {
-  try {
-    while (true) {
-      if (result.done) {
-        break;
-      }
-      if (!result.messages.length) {
-        await result.deferred?.promise;
-        if (result.error) {
-          throw result.error;
-        }
+  while (true) {
+    if (result.done) {
+      break;
+    }
+    if (!result.messages.length) {
+      await result.deferred?.promise;
+      if (result.error) {
+        throw result.error;
       }
-      let message = result.messages.shift();
-      while (message) {
-        if (message.event === ChatEventType.DONE) {
-          yield {
-            event: message.event,
-            data: '[DONE]',
-          };
-        } else {
-          yield {
-            event: message.event,
-            data: JSON.parse(message.data),
-          };
-        }
-        message = result.messages.shift();
+    }
+    let message = result.messages.shift();
+    while (message) {
+      if (message.event === ChatEventType.DONE) {
+        yield {
+          event: message.event,
+          data: '[DONE]',
+        };
+      } else {
+        yield {
+          event: message.event,
+          data: JSON.parse(message.data),
+        };
       }
+      message = result.messages.shift();
     }
-  } catch (e) {
-    const msg = e instanceof Error ? e.message : e;
-    throw new CozeError(`Could not handle message: ${msg}`);
   }
 }
diff --git a/packages/coze-taro/src/mixins/platform.ts b/packages/coze-taro/src/mixins/platform.ts
index c0954596..faeb1a00 100644
--- a/packages/coze-taro/src/mixins/platform.ts
+++ b/packages/coze-taro/src/mixins/platform.ts
@@ -1,8 +1,17 @@
+import { getEnv } from '@tarojs/taro';
+
 import { type CozeAPI } from '../api';
+import { platformMixins as platformMixinsWeapp } from './platform.weapp';
+import { platformMixins as platformMixinsTT } from './platform.tt';
 
 /**
  * Default implementation for multiple platforms, used only for type compatibility.
  */
-export function platformMixins(_: CozeAPI) {
+export function platformMixins(api: CozeAPI) {
+  if (getEnv() === 'TT') {
+    return platformMixinsTT(api);
+  } else if (getEnv() === 'WEAPP') {
+    return platformMixinsWeapp(api);
+  }
   // donothing
 }
diff --git a/packages/coze-taro/test/api.h5.spec.ts b/packages/coze-taro/test/api.h5.spec.ts
deleted file mode 100644
index c110eb6a..00000000
--- a/packages/coze-taro/test/api.h5.spec.ts
+++ /dev/null
@@ -1,34 +0,0 @@
-import { CozeAPI } from '../src/api/index.h5';
-
-describe('CozeAPI - h5', () => {
-  it('should call onBeforeAPICall', async () => {
-    const mockOnBeforeAPICall = vi.fn();
-
-    const cozeApi = new CozeAPI({
-      baseURL: 'xx',
-      token: '',
-      onBeforeAPICall: mockOnBeforeAPICall,
-    });
-    try {
-      await cozeApi.workflows.runs.create({ workflow_id: 'xx' });
-    } catch (e) {
-      // donothing
-    }
-    expect(mockOnBeforeAPICall).toHaveBeenCalledOnce();
-  });
-
-  it('should refresh token', async () => {
-    const cozeApi = new CozeAPI({
-      baseURL: 'xx',
-      token: '',
-      onBeforeAPICall: () => ({ token: 'newToken' }),
-    });
-    expect(cozeApi.token).toEqual('');
-    try {
-      await cozeApi.workflows.runs.create({ workflow_id: 'xx' });
-    } catch (e) {
-      // donothing
-    }
-    expect(cozeApi.token).toEqual('newToken');
-  });
-});
diff --git a/packages/coze-taro/test/api.spec.ts b/packages/coze-taro/test/api.spec.ts
index 21e40e72..6ecd40f4 100644
--- a/packages/coze-taro/test/api.spec.ts
+++ b/packages/coze-taro/test/api.spec.ts
@@ -1,19 +1,4 @@
 import { CozeAPI } from '../src/api';
-import { ttCreateEventSource } from './stubs';
-
-vi.stubGlobal('tt', {
-  createEventSource: ttCreateEventSource,
-});
-
-vi.mock('../src/mixins/platform', async () => {
-  const mod = await vi.importActual('../src/mixins/platform.tt');
-  return mod;
-});
-
-vi.mock('../src/event-source/index', async () => {
-  const mod = await vi.importActual('../src/event-source/index.tt');
-  return mod;
-});
 
 describe('CozeAPI - mini', () => {
   beforeEach(() => {
@@ -40,6 +25,11 @@ describe('CozeAPI - mini', () => {
         caches.push(chunk);
       }
       expect(mockOnBeforeAPICall).toHaveBeenCalledOnce();
+
+      await cozeApi.workflows.runs.create({
+        workflow_id: 'nonStreaming',
+      });
+      expect(mockOnBeforeAPICall).toHaveBeenCalledTimes(2);
     });
 
     it('should refresh token', async () => {
diff --git a/packages/coze-taro/test/request.spec.ts b/packages/coze-taro/test/request.spec.ts
index 4104164e..ff27b573 100644
--- a/packages/coze-taro/test/request.spec.ts
+++ b/packages/coze-taro/test/request.spec.ts
@@ -1,16 +1,6 @@
 import { type Deferred } from '../src/helpers/async';
 import { AbortController } from '../src/helpers/abortcontroller';
 import { sendRequest } from '../src/event-source/request';
-import { ttCreateEventSource } from './stubs';
-
-vi.stubGlobal('tt', {
-  createEventSource: ttCreateEventSource,
-});
-
-vi.mock('../src/event-source/index', async () => {
-  const mod = await vi.importActual('../src/event-source/index.tt');
-  return mod;
-});
 
 describe('SSERequest', () => {
   beforeEach(() => {
@@ -49,6 +39,12 @@ describe('SSERequest', () => {
       deferred: null,
       error: null,
     };
+
+    const unhandle = () => {
+      // donothing
+    };
+    process.on('unhandledRejection', unhandle);
+
     const controller = new AbortController();
     sendRequest({ url: 'xx', signal: controller.signal }, result);
 
@@ -56,7 +52,7 @@ describe('SSERequest', () => {
       controller.abort();
     }, 5);
 
-    vi.runAllTimersAsync();
+    await vi.runAllTimersAsync();
     await expect(result.deferred?.promise).rejects.toThrowError();
     expect(result.done).toBe(true);
   });
diff --git a/packages/coze-taro/test/setup.ts b/packages/coze-taro/test/setup.ts
index 05606af3..d2ad378d 100644
--- a/packages/coze-taro/test/setup.ts
+++ b/packages/coze-taro/test/setup.ts
@@ -1,10 +1,15 @@
-import { Events, taroStreamingRequest, taroUploadFile } from './stubs';
+import { Events, taroRequest, taroUploadFile } from './stubs';
 
 vi.doMock('@tarojs/taro', () => ({
   default: {
     Events,
-    request: taroStreamingRequest,
+    request: taroRequest,
     uploadFile: taroUploadFile,
   },
   Events,
+  request: taroRequest,
+  getEnv: () => 'WEAPP',
+  ENV_TYPE: {
+    WEB: 'WEB',
+  },
 }));
diff --git a/packages/coze-taro/test/stubs.ts b/packages/coze-taro/test/stubs.ts
index 5d345779..60077b41 100644
--- a/packages/coze-taro/test/stubs.ts
+++ b/packages/coze-taro/test/stubs.ts
@@ -194,18 +194,30 @@ export const ttCreateEventSource: TTCreateEVentSource = ({ data, timeout }) => {
   return task;
 };
 
-export const taroStreamingRequest = ({
+export const taroRequest = ({
+  data,
+  timeout,
   fail,
   success,
 }: {
+  data?: Record<string, unknown>;
+  timeout?: number;
   fail: (err: { errMsg: string }) => void;
   success: (res: { statusCode: number; errMsg?: string }) => void;
 }) => {
+  if (data?.workflow_id === 'nonStreaming') {
+    return Promise.resolve({ statusCode: 200 });
+  }
+
   const task = new TaroStreamingTask();
 
   let index = 0;
   const mockReceiveMessage = () => {
-    if (index < mockWorkflowMessages.length && !task.closed) {
+    if (data && data.workflow_id && data.workflow_id === 'fail') {
+      setTimeout(() => {
+        fail({ errMsg: 'fail' });
+      }, 10);
+    } else if (index < mockWorkflowMessages.length && !task.closed) {
       setTimeout(() => {
         if (index === 2) {
           // mock long message split
@@ -234,6 +246,11 @@ export const taroStreamingRequest = ({
   setTimeout(() => {
     task.events.trigger('headersReceived');
     mockReceiveMessage();
+    if (timeout) {
+      setTimeout(() => {
+        task.abort();
+      }, timeout);
+    }
   }, 0);
 
   return task;