fix: remove stream api (#11420)

[TD-14360]

src/client/src/taos.def

@@ -41,8 +41,6 @@ taos_fetch_rows_a
 taos_subscribe
 taos_consume
 taos_unsubscribe
-taos_open_stream
-taos_close_stream
 taos_load_table_info
 taos_data_type
 taos_stmt_set_sub_tbname
@@ -57,4 +55,4 @@ taos_print_row_ex
 taos_stmt_affected_rows
 taos_is_update_query
 taos_reset_current_db
-taos_parse_time
+taos_parse_time
\ No newline at end of file

src/client/src/tscProfile.c

@@ -24,6 +24,7 @@
 #include "taos.h"
 #include "tscUtil.h"
 
+void taos_close_stream(TAOS_STREAM *handle);
 void  tscSaveSlowQueryFp(void *handle, void *tmrId);
 TAOS *tscSlowQueryConn = NULL;
 bool  tscSlowQueryConnInitialized = false;

src/client/src/tscStream.c

@@ -26,6 +26,7 @@
 #include "tscProfile.h"
 #include "tscSubquery.h"
 
+void taos_close_stream(TAOS_STREAM *handle);
 static void tscProcessStreamQueryCallback(void *param, TAOS_RES *tres, int numOfRows);
 static void tscProcessStreamRetrieveResult(void *param, TAOS_RES *res, int numOfRows);
 static void tscSetNextLaunchTimer(SSqlStream *pStream, SSqlObj *pSql);

src/cq/src/cqMain.c

@@ -54,6 +54,7 @@ typedef struct SCqObj {
   SCqContext *   pContext;
 } SCqObj;
 
+void taos_close_stream(TAOS_STREAM *handle);
 static void cqProcessStreamRes(void *param, TAOS_RES *tres, TAOS_ROW row); 
 static void cqCreateStream(SCqContext *pContext, SCqObj *pObj);
 

src/inc/taos.h

@@ -206,10 +206,6 @@ DLL_EXPORT TAOS_SUB *taos_subscribe(TAOS* taos, int restart, const char* topic,
 DLL_EXPORT TAOS_RES *taos_consume(TAOS_SUB *tsub);
 DLL_EXPORT void      taos_unsubscribe(TAOS_SUB *tsub, int keepProgress);
 
-DLL_EXPORT TAOS_STREAM *taos_open_stream(TAOS *taos, const char *sql, void (*fp)(void *param, TAOS_RES *, TAOS_ROW row),
-                              int64_t stime, void *param, void (*callback)(void *));
-DLL_EXPORT void taos_close_stream(TAOS_STREAM *tstr);
-
 DLL_EXPORT int taos_load_table_info(TAOS *taos, const char* tableNameList);
 
 DLL_EXPORT TAOS_RES *taos_schemaless_insert(TAOS* taos, char* lines[], int numLines, int protocol, int precision);