1 /* 2 * Copyright (c) 2024 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 16 #ifndef OHOS_REQUEST_CJ_NOTIFY_DATA_LISTENER_H 17 #define OHOS_REQUEST_CJ_NOTIFY_DATA_LISTENER_H 18 19 #include "cj_listener_list.h" 20 #include "i_notify_data_listener.h" 21 #include "request_common.h" 22 23 namespace OHOS::CJSystemapi::Request { 24 using OHOS::Request::INotifyDataListener; 25 using OHOS::Request::NotifyData; 26 using OHOS::Request::SubscribeType; 27 using OHOS::Request::Reason; 28 29 class CJNotifyDataListener : public INotifyDataListener, 30 public ListenerList, 31 public std::enable_shared_from_this<CJNotifyDataListener> { 32 public: CJNotifyDataListener(const std::string & taskId,const SubscribeType & type)33 CJNotifyDataListener(const std::string &taskId, const SubscribeType &type) : ListenerList(taskId, type) 34 { 35 } 36 void AddListener(std::function<void(CProgress)> cb, CFunc cbId); 37 void RemoveListener(CFunc cbId = nullptr); 38 void OnNotifyDataReceive(const std::shared_ptr<NotifyData> ¬ifyData) override; 39 void OnFaultsReceive(const std::shared_ptr<int32_t> &tid, const std::shared_ptr<SubscribeType> &type, 40 const std::shared_ptr<Reason> &reason) override; 41 void OnWaitReceive(std::int32_t taskId, OHOS::Request::WaitingReason reason) override; 42 43 private: 44 bool IsHeaderReceive(const std::shared_ptr<NotifyData> ¬ifyData); 45 void ProcessHeaderReceive(const std::shared_ptr<NotifyData> ¬ifyData); 46 void NotifyDataProcess(const std::shared_ptr<NotifyData> ¬ifyData); 47 }; 48 49 } // namespace OHOS::CJSystemapi::Request 50 51 #endif // OHOS_REQUEST_JS_NOTIFY_DATA_LISTENER_H 52