Searched refs:R (Results 1 – 25 of 626) sorted by relevance
12345678910>>...26
94 R"("userGrantPermissions":[)"\185 R"("userGrantPermissions":[]})";194 R"("userGrantPermissions":[]})";202 R"("userGrantPermissions":[]})";210 R"("userGrantPermissions":[]})";228 R"("userGrantPermissions":[]})";235 R"("userGrantPermissions":[)"\244 R"("userGrantPermissions":[)"\265 R"("userGrantPermissions":[]})";323 R"("userGrantPermissions":[)"\[all …]
56 unsafe impl<R: Send> Send for JoinSet<R> {}58 unsafe impl<R: Send> Sync for JoinSet<R> {}70 impl<R> Default for JoinList<R> {91 impl<R> JoinSet<R> {101 impl<R> PartialEq<Self> for JoinEntry<R> {107 impl<R> Eq for JoinEntry<R> {}109 impl<R> Hash for JoinEntry<R> {115 impl<R> JoinEntry<R> {139 impl<R> JoinSet<R> {351 impl<'a, R> Builder<'a, R> {[all …]
47 pub struct JoinHandle<R> {49 marker: PhantomData<R>,52 unsafe impl<R: Send> Send for JoinHandle<R> {}53 unsafe impl<R: Send> Sync for JoinHandle<R> {}55 impl<R> JoinHandle<R> {56 pub(crate) fn new(raw: RawTask) -> JoinHandle<R> { in new() argument96 impl<R> Unpin for JoinHandle<R> {}98 impl<R> Future for JoinHandle<R> {100 type Output = Result<R, ScheduleError>;114 .get_result((&mut res as *mut Poll<Result<R, ScheduleError>>).cast::<()>()); in poll()[all …]
45 impl<'a, R: ?Sized> ReadTask<'a, R> {55 impl<'a, R> Future for ReadTask<'a, R>85 impl<'a, R: ?Sized> ReadToEndTask<'a, R> {133 impl<'a, R> Future for ReadToEndTask<'a, R>230 impl<'a, R: ?Sized> ReadExactTask<'a, R> {280 impl<'a, R: ?Sized> ReadUtilTask<'a, R> {324 impl<'a, R> Future for ReadUtilTask<'a, R>348 impl<'a, R: ?Sized> ReadLineTask<'a, R> {388 impl<R> SplitTask<R>432 impl<R> LinesTask<R>[all …]
138 std::string dJson = R"({153 PairType { R"("d1":1)", R"("d1":"1")" }, PairType { R"("d2":"true")", R"("d2":true)" },154 PairType { R"("d3":true)", R"("d3":"true")" }161 std::string eJson = R"({180 PairType { R"("d1":1)", R"("d1":"1")" }, PairType { R"("r":1)", R"("r":"1")" },181 PairType { R"("g":"foo")", R"("g":1)" }, PairType { R"("b":true)", R"("b":"true")" },182 PairType { R"("d2": {193 std::string hJson = R"({218 PairType { R"("d1":1)", R"("d1":"1")" }, PairType { R"("d1":2)", R"("d1":"2")" },219 PairType { R"("d1":3)", R"("d1":"3")" }, PairType { R"("d2":true)", R"("d2":"true")" },[all …]
62 std::string str = R"({"key"})";70 std::string str = R"({"key": "value1"})";85 std::string str = R"({"key": 1})";93 std::string str = R"({"key": true})";120 std::string str = R"({"key1": null})";127 std::string str = R"({"key":})";134 static const std::string str = R"(235 std::string str = R"({"key":1})";244 std::string str = R"({"key":true})";262 std::string str = R"({"key1":{[all …]
77 std::string update = R""({"CC":"AAAA"})"";130 std::string filter = R""({"_id":"1234"})"";146 std::string filter = R""({"_id":"1234"})"";161 std::string filter = R""({"_id":"1234"})"";172 std::string head = R"({"field1": ")";182 …int result = GRD_UpsertDoc(g_db, g_coll, R"({"_id" : "abcde"})", R"({"a00001": {"A":1, "A":2}})", …189 …GRD_UpsertDoc(g_db, g_coll, R"({"_id" : "abcde"})", R"({"t1":{"t22":[1,{"t23":1, "t23":1},3 ,4]}})…228 std::string filter = R""({"_id":"1234"})"";242 std::string filter = R""({"_id":"1234"})"";361 int result = GRD_UpdateDoc(g_db, "GM_Sys", R""({})"", R""({})"", 0);[all …]
27 infos.append(R"( "accessRecords": [)"); in DetailUsedRecordToString()29 infos.append(R"( "rejectRecords": [)"); in DetailUsedRecordToString()36 infos.append(R"( "lockScreenStatus": ")" + std::to_string( in DetailUsedRecordToString()40 infos.append(R"( "count": )" + std::to_string(detail.count) + ",\n"); in DetailUsedRecordToString()75 infos.append(R"( "bundleName": )" + bundleRecord.bundleName + ",\n"); in BundleUsedRecordToString()77 infos.append(R"( "permissionRecords": [)"); in BundleUsedRecordToString()96 infos.append(R"( "endTime": )" + std::to_string(result.endTimeMillis) + ",\n"); in PermissionUsedResultToString()97 infos.append(R"( "bundleRecords": [)"); in PermissionUsedResultToString()113 infos.append(R"( "tokenId": )" + std::to_string(info.tokenId) + ",\n"); in PermissionUsedTypeInfoToString()114 infos.append(R"( "permissionName": )" + info.permissionName + ",\n"); in PermissionUsedTypeInfoToString()[all …]
35 T: FnOnce() -> R,37 type Output = R;47 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R>49 T: FnOnce() -> R,51 R: Send + 'static,60 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking() argument62 T: FnOnce() -> R, in spawn_blocking()64 R: Send + 'static, in spawn_blocking()73 pub(crate) fn spawn_async<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_async()75 T: Future<Output = R>, in spawn_async()[all …]
120 std::string updateDoc = R""({"name.5":"GG"})"";134 std::string updateDoc = R""({"name.2":"GG"})"";153 std::string updateDoc = R""({"name.first.0":"LL"})"";244 std::string updateDoc = R""({"name.first":"GG"})"";272 std::string updateDoc = R""({"name.0":"GG"})"";336 std::string filter = R""({"item": "GG"})"";348 std::string filter = R""({"item": "GG"})"";360 std::string filter = R""({"item": ["GG", "AA"]})"";372 std::string filter = R""({"item.0": "GG"})"";456 std::string filter = R""({"instock.qty" : 15})"";[all …]
61 pub fn reader<R: AsyncRead>(self, reader: R) -> UploaderBuilder<WantsOperator<R>> { in reader() argument98 pub struct WantsOperator<R> {99 reader: R,103 impl<R: AsyncRead> UploaderBuilder<WantsOperator<R>> {132 pub fn operator<T: UploadOperator>(self, operator: T) -> UploaderBuilder<WantsConfig<R, T>> { in operator() argument155 pub fn console(self) -> UploaderBuilder<WantsConfig<R, Console>> { in console() argument167 pub struct WantsConfig<R, T> {168 reader: R,173 impl<R, T> UploaderBuilder<WantsConfig<R, T>> {206 pub fn build(self) -> Uploader<R, T> { in build() argument
89 pub struct Uploader<R, T> {90 reader: R,96 impl<R: AsyncRead + Unpin> Uploader<R, Console> {106 pub fn console(reader: R) -> Uploader<R, Console> { in console() argument126 impl<R, T> AsyncRead for Uploader<R, T>128 R: AsyncRead + Unpin,170 impl<R, U> From<Uploader<R, U>> for reqwest::Body172 R: AsyncRead + Send + Sync + Unpin + 'static,175 fn from(value: Uploader<R, U>) -> Self { in from() argument180 impl<R, T> AsRef<R> for Uploader<R, T> {[all …]
62 pub fn reader<R: AsyncRead>(self, reader: R) -> UploaderBuilder<WantsOperator<R>> { in reader() argument99 pub struct WantsOperator<R> {100 reader: R,104 impl<R: AsyncRead> UploaderBuilder<WantsOperator<R>> {134 pub fn operator<T: UploadOperator>(self, operator: T) -> UploaderBuilder<WantsConfig<R, T>> { in operator() argument158 pub fn console(self) -> UploaderBuilder<WantsConfig<R, Console>> { in console() argument170 pub struct WantsConfig<R, T> {171 reader: R,176 impl<R, T> UploaderBuilder<WantsConfig<R, T>> {209 pub fn build(self) -> Uploader<R, T> { in build() argument
74 template <typename R>94 R& get() noexcept in get()107 std::optional<R> m_res;137 template <typename R>170 R get() noexcept206 template <typename R>234 future<R> get_future() noexcept236 return future<R> {m_state};289 struct packaged_task<R(Args...)> {323 future<R> get_future() noexcept[all …]
84 pub fn post_sync_task<F, R>(&self, task: F) -> R in post_sync_task()86 F: Fn() -> R + Send + 'static, in post_sync_task()87 R: Send + 'static, in post_sync_task()116 pub fn post_async_task<F, R>(&self, task: F) -> TaskHandle<R> in post_async_task()118 F: Fn() -> R + Send + 'static, in post_async_task()119 R: Send + 'static, in post_async_task()132 pub fn post_delayed_task<F, R>(&self, task: F, delay: Duration) -> TaskHandle<R> in post_delayed_task()134 F: Fn() -> R + Send + 'static, in post_delayed_task()135 R: Send + 'static, in post_delayed_task()174 pub fn post_blocking_task<F, R>(&self, task: F) -> TaskHandle<R> in post_blocking_task()[all …]
22 pub struct TaskHandle<R> {23 join_handle: Option<JoinHandle<R>>,26 impl<R> From<JoinHandle<R>> for TaskHandle<R> {27 fn from(value: JoinHandle<R>) -> Self in from()35 impl<R> TaskHandle<R> {45 pub fn result(&mut self) -> FusionResult<R> in result() argument
33 pub struct AsyncBufReader<R> {34 inner: R,40 impl<R: AsyncRead> AsyncBufReader<R> {57 pub fn new(inner: R) -> AsyncBufReader<R> { in new() argument74 pub fn with_capacity(capacity: usize, inner: R) -> AsyncBufReader<R> { in with_capacity() argument84 impl<R> AsyncBufReader<R> {100 pub fn get_ref(&self) -> &R { in get_ref() argument180 impl<R: AsyncRead> AsyncRead for AsyncBufReader<R> {200 impl<R: AsyncRead> AsyncBufRead for AsyncBufReader<R> {220 impl<R: AsyncRead + AsyncSeek> AsyncSeek for AsyncBufReader<R> {[all …]
65 std::string assetJsonsStr = R"({})";69 assetJsonsStr = R"({"applinking":1})";73 assetJsonsStr = R"({"applinkings":1})";77 assetJsonsStr = R"({"applinking":1})";81 assetJsonsStr = R"({"applinking":{})";85 assetJsonsStr = R"({"applinking":{"apps":123})";89 assetJsonsStr = R"({"applinking":{"apps":[{"bundleName":1,"fingerprint":1}]}})";93 assetJsonsStr = R"({"applinking":{"apps":[{"appIdentifier":1,"fingerprint":1}]}})";97 assetJsonsStr = R"({"applinking":{"apps":[{"appIdentifier":1,"bundleName":1,}]}})";101 …assetJsonsStr = R"({"applinking":{"apps":[{"bundleName":"bundleName","fingerprint":"fingerprint"}]…[all …]
191 pub fn spawn<T, R>(&self, task: T) -> JoinHandle<R> in spawn()194 R: Send + 'static, in spawn()203 R: Send + 'static, in spawn_with_attr()237 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking()240 R: Send + 'static, in spawn_blocking()277 pub fn block_on<T, R>(&self, task: T) -> R in block_on()279 T: Future<Output = R>, in block_on()285 fn block_on_inner<T, R>(&self, task: T) -> R in block_on_inner()287 T: Future<Output = R>, in block_on_inner()325 fn block_on_inner<T, R>(&self, task: T) -> R in block_on_inner()[all …]
Error! Your browser does not support the video tag. There was an error! Java heap space java.lang.OutOfMemoryError: Java heap space
Java heap space
java.lang.OutOfMemoryError: Java heap space